के बाद कई उपभोक्ताओं (काफ्का 0.9 जावा एपीआई का उपयोग कर) बना सकते हैं और प्रत्येक थ्रेड शुरू कर दिया, मैं निम्नलिखित अपवादकाफ्का CommitFailedException उपभोक्ता अपवाद
Consumer has failed with exception: org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed due to group rebalance
class com.messagehub.consumer.Consumer is shutting down.
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 org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.java:905)
और उसके बाद सामान्य रूप से लेने वाली संदेश शुरू हो रही है, मुझे पता है कि क्या करना चाहते हैं इसे ठीक करने के लिए इस अपवाद का कारण बन रहा है।
ह्यूगो, क्या आप अभी भी इस समस्या का सामना कर रहे हैं? क्या आप कुछ और जानकारी प्रदान कर सकते हैं? – Nautilus
हां @ नॉटिलस, मुझे अभी भी यह समस्या है। मेरे पास 3 उपभोक्ता हैं, सभी एक ही उपभोक्ता समूह में, मेरे पास 20 विभाजन वाले विषय हैं, जहां से डेटा पढ़ा जाना चाहिए। यह अपवाद यादृच्छिक रूप से होता है, फिर भी उपभोक्ता विषय/विभाजन से डेटा पढ़ सकते हैं, हालांकि यह अपवाद ट्रिगर किया गया है। –
उपभोक्ता केवल डेटा उपभोग कर रहे हैं या वे इसे संसाधित कर रहे हैं?मैं आपके स्टैकट्रैस पर देखता हूं कि अपवाद तब होता है जब आप ऑफसेट को सिंक करने की कोशिश कर रहे हैं, क्या आप वर्णन कर सकते हैं कि संदेशों की खपत और ऑफसेट की प्रतिबद्धता के बीच क्या होता है? मुझे लगता है कि यह संभव है कि आपका उपभोक्ता समन्वयक के साथ दिल की धड़कन खो रहा है। – Nautilus