Some Kafka consumers become idle after some Kafka nodes restart

[GenTang]

Bug Report

When some nodes of Kafka restart, some Kafka consumers in Ligase become idle, not consume any messages.

If we check Kafka by kafka-consumer-groups --bootstrap-server localhost:9093 --describe --all-groups, there are some groups that has no consumer-id for some topic.

1. Minimal reproduce step (Required)

• Create some Kafka topics and send messages to these topics
• Consume these topics as the way of Ligase (Extract the Kafka consume code)
• Restart Kafka node several times

2. What did you expect to see? (Required)

Consumer continue consuming message

3. What did you see instead (Required)

Consumer become idle and does not consume message and no error is raised.
Or restart consumer service.

4. Root Cause Analysis

It seems that this bug is related to this sdk bug