Can you please check the broker logs for errors?

Ismael

On Tue, Dec 12, 2017 at 12:10 PM, Sameer Kumar <sam.kum.w...@gmail.com>
wrote:

> Hi All,
>
> Facing an strange exception while running Kafka Streams. I am reading from
> a topic of 60 partitions. I am using exactly once in Kafka 1.0.0.
>
> Now, this error has started appearing recently. The application runs fine
> on 2 nodes, but as soon as a 3rd node is added, it starts throwing
> exception. Please find the stacktrace attached.
>
> 2017-12-12 15:32:55 ERROR Kafka010Base:47 - Exception caught in thread
> c-7-aq32-5648256f-9142-49e2-98c0-da792e6da48e-StreamThread-5
> org.apache.kafka.common.KafkaException: Unexpected error from SyncGroup:
> The server experienced an unexpected error when processing the request
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.
> java:566)
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.
> java:539)
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator$CoordinatorResponseHandler.
> onSuccess(AbstractCoordinator.java:808)
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator$CoordinatorResponseHandler.
> onSuccess(AbstractCoordinator.java:788)
>         at org.apache.kafka.clients.consumer.internals.
> RequestFuture$1.onSuccess(RequestFuture.java:204)
>         at org.apache.kafka.clients.consumer.internals.
> RequestFuture.fireSuccess(RequestFuture.java:167)
>         at org.apache.kafka.clients.consumer.internals.
> RequestFuture.complete(RequestFuture.java:127)
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(
> ConsumerNetworkClient.java:506)
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerNetworkClient.firePendingCompletedRequests(
> ConsumerNetworkClient.java:353)
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerNetworkClient.poll(ConsumerNetworkClient.java:268)
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerNetworkClient.poll(ConsumerNetworkClient.java:214)
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerNetworkClient.poll(ConsumerNetworkClient.java:174)
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:364)
>         at org.apache.kafka.clients.consumer.internals.
> AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:316)
>         at org.apache.kafka.clients.consumer.internals.
> ConsumerCoordinator.poll(ConsumerCoordinator.java:295)
>         at org.apache.kafka.clients.consumer.KafkaConsumer.
> pollOnce(KafkaConsumer.java:1138)
>         at org.apache.kafka.clients.consumer.KafkaConsumer.poll(
> KafkaConsumer.java:1103)
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.pollRequests(StreamThread.java:851)
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.runOnce(StreamThread.java:808)
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.runLoop(StreamThread.java:774)
>         at org.apache.kafka.streams.processor.internals.
> StreamThread.run(StreamThread.java:744)
>
>
>
> -Sameer.
>

Reply via email to