Skip to Content
0
Dec 12, 2018 at 06:53 AM

SAP HANA streaming analytics - Kafka JSON input adapater

441 Views

We get the following error while trying to stream the data from Kafka JSON adapter. The current configuration, we have not set any parameter for "Kafka Consumer Properties FIle Path' or "Kafka Consumer Poll interval" . Kindly suggest what could be the reason behind this error . Also suggest how we could place the file in that path and what paramters can be set:

12-11-2018 16:59:30.377 INFO 47044@XXXXX[Thread-15] (AbstractCoordinator.coordinatorDead) Marking the coordinator 2147482644 dead.

12-11-2018 16:59:30.379 ERROR 47044@XXXXX [Thread-15] (ConsumerCoordinator$OffsetCommitResponseHandler.handle) Error UNKNOWN_MEMBER_ID occurred while committing offsets for group Default

12-11-2018 16:59:30.382 ERROR 47044@XXXXX [Thread-15] (AdapterEventManager.processEvent) Exception is thrown

org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed due to group rebalance

at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle(ConsumerCoordinator.java:546)

at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle(ConsumerCoordinator.java:487)

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

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

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

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

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

at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:350)

at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:288)

at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:303)

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

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

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

at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.commitOffsetsSync(ConsumerCoordinator.java:352)

at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:936)

at com.sybase.esp.adapter.transporters.kafka.KafkaInputTransporter$GdEventListener.handlePublishSuccess(KafkaInputTransporter.java:648)

at com.sybase.esp.adapter.transporters.kafka.KafkaInputTransporter$GdEventListener.adapterEventPerformed(KafkaInputTransporter.java:633)

at com.sybase.esp.adapter.framework.internal.AdapterEventManager.processEvent(AdapterEventManager.java:148)

at com.sybase.esp.adapter.framework.internal.AdapterEventManager.run(AdapterEventManager.java:221)

at java.lang.Thread.run(Thread.java:808)