美文网首页Kafka
onPartitionRevoked和onPartitionAs

onPartitionRevoked和onPartitionAs

作者: Alen_ab56 | 来源:发表于2022-04-20 19:54 被阅读0次

第一个是刚开始重平衡 还没开始

第二是已经分配好了

建议你在第一个回调里提交offset

第二个回调里获取offset进行重置

public void onPartitionsRevoked(Collection<TopicPartition> collection) {

                consumer.commitAsync(); // 提交偏移量

            }

            public void onPartitionsAssigned(Collection<TopicPartition> partitions) {

                // 获取该分区下已消费的偏移量

                long commitedOffset = -1;

                for (TopicPartition topicPartition : partitions) {

                    // 获取该分区下已消费的偏移量

                    commitedOffset = consumer.committed(topicPartition).offset();

                    // 重置偏移量到上一次提交的偏移量下一个位置处开始消费

                    consumer.seek(topicPartition, commitedOffset + 1);

                }

            }

assign不受这个影响

这个是subscribe方式进行消费

相关文章

网友评论

    本文标题:onPartitionRevoked和onPartitionAs

    本文链接:https://www.haomeiwen.com/subject/swxbertx.html