You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm trying to use it at its best to get the maximum throughput in my application.
I got some issue when scaling up and down my app, due to "infinite rebalance".
I feel that something may be going wrong between these two configurations : PERIODIC_CONSUMER_ASYNCHRONOUS and "partition.assignment.strategy" = org.apache.kafka.clients.consumer.CooperativeStickyAssignor
I would be very helpful to add topic/partition/offset that are tried to be commited in this log (Ideally the ones that failed)
I don't see these informations in the current message
{extendedStackTrace=org.apache.kafka.common.errors.RebalanceInProgressException: Offset commit cannot be completed since the consumer is undergoing a rebalance for auto partition assignment. You can try completing the rebalance by calling poll() and then retry the operation.
, localizedMessage=Offset commit cannot be completed since the consumer is undergoing a rebalance for auto partition assignment. You can try completing the rebalance by calling poll() and then retry the operation., name=org.apache.kafka.common.errors.RebalanceInProgressException, commonElementCount=0, message=Offset commit cannot be completed since the consumer is undergoing a rebalance for auto partition assignment. You can try completing the rebalance by calling poll() and then retry the operation.}
Regards,
Benoit
The text was updated successfully, but these errors were encountered:
First thanks for this library,
I'm trying to use it at its best to get the maximum throughput in my application.
I got some issue when scaling up and down my app, due to "infinite rebalance".
I feel that something may be going wrong between these two configurations : PERIODIC_CONSUMER_ASYNCHRONOUS and "partition.assignment.strategy" = org.apache.kafka.clients.consumer.CooperativeStickyAssignor
I would be very helpful to add topic/partition/offset that are tried to be commited in this log (Ideally the ones that failed)
https://github.com/confluentinc/parallel-consumer/blob/master/parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ConsumerOffsetCommitter.java#L100
I don't see these informations in the current message
Regards,
Benoit
The text was updated successfully, but these errors were encountered: