C#操作kafka
1.手动设置TopicPartition=>offset
//手动设置TopicPartition=>offset foreach (TopicPartition partition in consumer.Assignment) { if (partition.Partition.Value == 13) { TopicPartitionOffset offset = new TopicPartitionOffset(partition, 27060); consumer.Seek(offset); } }
2.手动指定kafka的Partition
List<TopicPartition> list = new List<TopicPartition>(); for (int i = 0; i < 30; i++) { TopicPartition p = new TopicPartition("test.pdf", new Partition(i)); list.Add(p); } consumer.Assign(list);
作者：九年新
出处：
如果您觉得文章对您有帮助的话，欢迎 点赞 关注 收藏 打赏，也可以在打赏标签扫红包码领取红包哦！
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文链接，否则保留追究法律责任的权利。