You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Randall Hauch (Jira)" <ji...@apache.org> on 2020/06/05 15:03:00 UTC
[jira] [Updated] (KAFKA-10110) ConnectDistributed fails with NPE
when Kafka cluster has no ID
[ https://issues.apache.org/jira/browse/KAFKA-10110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Randall Hauch updated KAFKA-10110:
----------------------------------
Description:
When a Connect worker starts, recent changes from KIP-606 / KAFKA-9960 attempt to put the Kafka cluster ID into the new KafkaMetricsContext. But the Kafka cluster ID can be null, resulting in an NPE shown in the following log snippet:
{noformat}
[2020-06-04 15:01:02,900] INFO Kafka cluster ID: null (org.apache.kafka.connect.util.ConnectUtils)
...
[2020-06-04 15:01:03,271] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed)
java.lang.NullPointerException
at org.apache.kafka.common.metrics.KafkaMetricsContext.lambda$new$0(KafkaMetricsContext.java:48)
at java.util.HashMap.forEach(HashMap.java:1289)
at org.apache.kafka.common.metrics.KafkaMetricsContext.<init>(KafkaMetricsContext.java:48)
at org.apache.kafka.connect.runtime.ConnectMetrics.<init>(ConnectMetrics.java:100)
at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:135)
at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:121)
at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:111)
at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:78)
{noformat}
was:
When a Connect worker starts, recent changes from KIP-606 / KAFKA-9960 attempt to put the Kafka cluster ID into the new KafkaMetricsContext. But the Kafka cluster ID can be null, resulting in an NPE shown in the following log snippet:
{noformat}
[2020-06-04 15:01:02,900] INFO Kafka cluster ID: null (org.apache.kafka.connect.util.ConnectUtils)
...
[2020-06-04 15:01:03,271] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed)[2020-06-04 15:01:03,271] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed)java.lang.NullPointerException at org.apache.kafka.common.metrics.KafkaMetricsContext.lambda$new$0(KafkaMetricsContext.java:48) at java.util.HashMap.forEach(HashMap.java:1289) at org.apache.kafka.common.metrics.KafkaMetricsContext.<init>(KafkaMetricsContext.java:48) at org.apache.kafka.connect.runtime.ConnectMetrics.<init>(ConnectMetrics.java:100) at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:135) at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:121) at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:111) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:78)
{noformat}
> ConnectDistributed fails with NPE when Kafka cluster has no ID
> --------------------------------------------------------------
>
> Key: KAFKA-10110
> URL: https://issues.apache.org/jira/browse/KAFKA-10110
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.6.0
> Reporter: Randall Hauch
> Assignee: Randall Hauch
> Priority: Blocker
> Fix For: 2.6.0
>
>
> When a Connect worker starts, recent changes from KIP-606 / KAFKA-9960 attempt to put the Kafka cluster ID into the new KafkaMetricsContext. But the Kafka cluster ID can be null, resulting in an NPE shown in the following log snippet:
> {noformat}
> [2020-06-04 15:01:02,900] INFO Kafka cluster ID: null (org.apache.kafka.connect.util.ConnectUtils)
> ...
> [2020-06-04 15:01:03,271] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed)
> java.lang.NullPointerException
> at org.apache.kafka.common.metrics.KafkaMetricsContext.lambda$new$0(KafkaMetricsContext.java:48)
> at java.util.HashMap.forEach(HashMap.java:1289)
> at org.apache.kafka.common.metrics.KafkaMetricsContext.<init>(KafkaMetricsContext.java:48)
> at org.apache.kafka.connect.runtime.ConnectMetrics.<init>(ConnectMetrics.java:100)
> at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:135)
> at org.apache.kafka.connect.runtime.Worker.<init>(Worker.java:121)
> at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:111)
> at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:78)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)