public class CommitFailedException extends KafkaException
KafkaConsumer.commitSync()
fails
with an unrecoverable error. This can happen when a group rebalance completes before the commit
could be successfully applied. In this case, the commit cannot generally be retried because some
of the partitions may have already been assigned to another member in the group.Constructor and Description |
---|
CommitFailedException() |
CommitFailedException(java.lang.String message) |