Seweryn Habdank-Wojewodzki created KAFKA-6260:
-------------------------------------------------
Summary: KafkaStream 1.0.0 does not strarts correctly with Broker
0.11.0.1
Key: KAFKA-6260
URL: https://issues.apache.org/jira/browse/KAFKA-6260
Project: Kafka
Issue Type: Bug
Reporter: Seweryn Habdank-Wojewodzki
The new KafkaStreams API, which uses StreamsBuilder class has troubles to
connect with Broker v. 0.11.0.1. Below there are logs.
The same app wich uses old API (v. 0.11.0.1) KStreamBuilder has no issues to
connect with Broker 0.11.0.1.
Can you check that?
{code}
2017-11-22 16:27:58 DEBUG NetworkClient:183 - [Consumer
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
groupId=kafka-endpoint] Disconnecting from node 1 due to request timeout.
2017-11-22 16:27:58 DEBUG ConsumerNetworkClient:195 - [Consumer
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
groupId=kafka-endpoint] Cancelled FETCH request RequestHeader(apiKey=FETCH,
apiVersion=5,
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
correlationId=74) with correlation id 74 due to node 1 being disconnected
2017-11-22 16:27:58 DEBUG Fetcher:195 - [Consumer
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
groupId=kafka-endpoint] Fetch request {my_internal_topic-4=(offset=199966200,
logStartOffset=-1, maxBytes=1048576), my_internal_topic-0=(offset=199987332,
logStartOffset=-1, maxBytes=1048576)} to myp01.eb.lan.at:9093 (id: 1 rack:
DC-1) failed org.apache.kafka.common.errors.DisconnectException: null
2017-11-22 16:27:58 DEBUG NetworkClient:183 - [Consumer
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
groupId=kafka-endpoint] Initialize connection to node myp01.eb.lan.at:9093
(id: 1 rack: DC-1) for sending metadata request 2017-11-22 16:27:58 DEBUG
NetworkClient:183 - [Consumer
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
groupId=kafka-endpoint] Initiating connection to node myp01.eb.lan.at:9093
(id: 1 rack: DC-1) 2017-11-22 16:27:58 ERROR AbstractCoordinator:296 -
[Consumer
clientId=kafka-endpoint-1a02a283-47e0-40b6-8da4-6e338da0814f-StreamThread-1-consumer,
groupId=kafka-endpoint] Heartbeat thread for group kafka-endpoint failed due
to unexpected errorjava.lang.NullPointerException: null
at
org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:436)
~[my-kafka-endpoint.jar:?]
at org.apache.kafka.common.network.Selector.poll(Selector.java:395)
~[my-kafka-endpoint.jar:?]
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:460)
~[my-kafka-endpoint.jar:?]
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:238)
~[my-kafka-endpoint.jar:?]
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.pollNoWakeup(ConsumerNetworkClient.java:275)
~[my-kafka-endpoint.jar:?]
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$HeartbeatThread.run(AbstractCoordinator.java:934)
[my-kafka-endpoint.jar:?]
{code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
