FATAL [mirrormaker-thread-1] Mirror maker thread failure due to (kafka.tools.MirrorMaker$MirrorMakerThread)

[Fernando Vega <fe...@turn.com>]

Can someone please help me with this error, this happening after upgrade
from 0.8.2 to 0.10.2.1.
It seem an issue with my consumers but I cannot determine what is happening.


INFO Kafka commitId : e89bffd6b2eff799
(org.apache.kafka.common.utils.AppInfoParser)

[2017-06-07 12:24:45,497] INFO [mirrormaker-thread-0] Starting mirror maker
thread mirrormaker-thread-0 (kafka.tools.MirrorMaker$MirrorMakerThread)

[2017-06-07 12:24:45,497] INFO [mirrormaker-thread-1] Starting mirror maker
thread mirrormaker-thread-1 (kafka.tools.MirrorMaker$MirrorMakerThread)

[2017-06-07 12:24:48,619] INFO Discovered coordinator
app458.sjc2.mytest.com:9092 (id: 2147483613 rack: null) for group
MirrorMaker_hkg1.
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator)

[2017-06-07 12:24:48,620] INFO Discovered coordinator
app458.sjc2.mytest.com:9092 (id: 2147483613 rack: null) for group
MirrorMaker_hkg1.
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator)

[2017-06-07 12:24:48,625] INFO Revoking previously assigned partitions []
for group MirrorMaker_hkg1
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)

[2017-06-07 12:24:48,625] INFO Revoking previously assigned partitions []
for group MirrorMaker_hkg1
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator)

[2017-06-07 12:24:48,648] INFO (Re-)joining group MirrorMaker_hkg1
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator)

[2017-06-07 12:24:48,649] INFO (Re-)joining group MirrorMaker_hkg1
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator)

[2017-06-07 12:24:53,560] FATAL [mirrormaker-thread-1] Mirror maker thread
failure due to  (kafka.tools.MirrorMaker$MirrorMakerThread)

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:548)

at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupResponseHandler.handle(AbstractCoordinator.java:521)

at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:784)

at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:765)

at
org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:186)

at
org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:149)

at
org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:116)

at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:493)

at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:322)

at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:253)

at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:172)

at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:347)

at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:303)

at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:290)

at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1029)

at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:995)

at
kafka.tools.MirrorMaker$MirrorMakerNewConsumer.receive(MirrorMaker.scala:625)

at kafka.tools.MirrorMaker$MirrorMakerThread.run(MirrorMaker.scala:431)