Randall Hauch created KAFKA-10110:
-------------------------------------
Summary: 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
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)[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)
