[
https://issues.apache.org/jira/browse/KAFKA-17445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohit Bobade updated KAFKA-17445:
---------------------------------
Description:
We recently upgraded Kafka streams version to 3.8.0 and are seeing that the
streams app keeps rebalancing and does not process any events
We have explicitly set the config
GROUP_INSTANCE_ID_CONFIG
This is what we see on the broker logs:
[GroupCoordinator 2]: Preparing to rebalance group \{consumer-group-name} in
state PreparingRebalance with old generation 24781 (__consumer_offsets-29)
(reason: Updating metadata for static member {} with instance id {}; client
reason: rebalance failed due to UnjoinedGroupException)
We also tried to remove the GROUP_INSTANCE_ID_CONFIG but then see these logs
and rebalancing and no processing still
sessionTimeoutMs=45000, rebalanceTimeoutMs=1800000,
supportedProtocols=List(stream)) has left group \{groupId} through explicit
`LeaveGroup`; client reason: the consumer unsubscribed from all topics
(kafka.coordinator.group.GroupCoordinator)
other logs show:
during Stable; client reason: need to revoke partitions and re-join)
client reason: triggered followup rebalance scheduled for 0
was:
We recently upgraded Kafka streams version to 3.8.0 and are seeing that the
consumer keeps rebalancing and does not process any events
We have explicitly set the config
GROUP_INSTANCE_ID_CONFIG
This is what we see on the broker logs:
[GroupCoordinator 2]: Preparing to rebalance group \{consumer-group-name} in
state PreparingRebalance with old generation 24781 (__consumer_offsets-29)
(reason: Updating metadata for static member {} with instance id {}; client
reason: rebalance failed due to UnjoinedGroupException)
We also tried to remove the GROUP_INSTANCE_ID_CONFIG but then see these logs
and rebalancing and no processing still
sessionTimeoutMs=45000, rebalanceTimeoutMs=1800000,
supportedProtocols=List(stream)) has left group \{groupId} through explicit
`LeaveGroup`; client reason: the consumer unsubscribed from all topics
(kafka.coordinator.group.GroupCoordinator)
other logs show:
during Stable; client reason: need to revoke partitions and re-join)
client reason: triggered followup rebalance scheduled for 0
> Kafka streams keeps rebalancing with the following reasons
> ----------------------------------------------------------
>
> Key: KAFKA-17445
> URL: https://issues.apache.org/jira/browse/KAFKA-17445
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 3.8.0
> Reporter: Rohit Bobade
> Priority: Major
>
> We recently upgraded Kafka streams version to 3.8.0 and are seeing that the
> streams app keeps rebalancing and does not process any events
> We have explicitly set the config
> GROUP_INSTANCE_ID_CONFIG
> This is what we see on the broker logs:
> [GroupCoordinator 2]: Preparing to rebalance group \{consumer-group-name} in
> state PreparingRebalance with old generation 24781 (__consumer_offsets-29)
> (reason: Updating metadata for static member {} with instance id {}; client
> reason: rebalance failed due to UnjoinedGroupException)
> We also tried to remove the GROUP_INSTANCE_ID_CONFIG but then see these logs
> and rebalancing and no processing still
> sessionTimeoutMs=45000, rebalanceTimeoutMs=1800000,
> supportedProtocols=List(stream)) has left group \{groupId} through explicit
> `LeaveGroup`; client reason: the consumer unsubscribed from all topics
> (kafka.coordinator.group.GroupCoordinator)
> other logs show:
> during Stable; client reason: need to revoke partitions and re-join)
> client reason: triggered followup rebalance scheduled for 0
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
