Boyang Chen created KAFKA-9701:
----------------------------------
Summary: Consumer could catch InconsistentGroupProtocolException
during rebalance
Key: KAFKA-9701
URL: https://issues.apache.org/jira/browse/KAFKA-9701
Project: Kafka
Issue Type: Bug
Affects Versions: 2.5.0
Reporter: Boyang Chen
INFO log shows that we accidentally hit an unexpected inconsistent group
protocol exception:
[2020-03-10T17:16:53-07:00]
(streams-soak-2-5-eos-broker-2-5_soak_i-00067445452c82fe8_streamslog)
[2020-03-11 *00:16:53,382*] INFO
[stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1]
stream-client [stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949] State
transition from REBALANCING to RUNNING (org.apache.kafka.streams.KafkaStreams)
[2020-03-10T17:16:53-07:00]
(streams-soak-2-5-eos-broker-2-5_soak_i-00067445452c82fe8_streamslog)
[2020-03-11 *00:16:53,384*] WARN [kafka-producer-network-thread |
stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1-0_1-producer]
stream-thread
[stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1] task
[0_1] Error sending record to topic node-name-repartition due to Producer
attempted an operation with an old epoch. Either there is a newer producer with
the same transactionalId, or the producer's transaction has been expired by the
broker.; No more records will be sent and no more offsets will be recorded for
this task.
[2020-03-10T17:16:53-07:00]
(streams-soak-2-5-eos-broker-2-5_soak_i-00067445452c82fe8_streamslog)
[2020-03-11 *00:16:53,521*] INFO
[stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1]
[Consumer
clientId=stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1-consumer,
groupId=stream-soak-test] Member
stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1-consumer-d1c3c796-0bfb-4c1c-9fb4-5a807d8b53a2
sending LeaveGroup request to coordinator
ip-172-31-20-215.us-west-2.compute.internal:9092 (id: 2147482646 rack: null)
due to the consumer unsubscribed from all topics
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[2020-03-10T17:16:54-07:00]
(streams-soak-2-5-eos-broker-2-5_soak_i-00067445452c82fe8_streamslog)
[2020-03-11 *00:16:53,798*] ERROR
[stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1]
stream-thread
[stream-soak-test-d3da8597-c371-450e-81d9-72aea6a26949-StreamThread-1]
Encountered the following unexpected Kafka exception during processing, this
usually indicate Streams internal errors:
(org.apache.kafka.streams.processor.internals.StreamThread)
[2020-03-10T17:16:54-07:00]
(streams-soak-2-5-eos-broker-2-5_soak_i-00067445452c82fe8_streamslog)
org.apache.kafka.common.errors.InconsistentGroupProtocolException: The group
member's supported protocols are incompatible with those of existing members or
first group member tried to join with empty protocol type or empty protocol
list.
Potentially needs further log to understand this.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
