2017-07-24 58 views
0

在confluent-kafka-dotnet v0.9.5上使用ProduceAsync方法写入Kafka上的同一主题时,它会覆盖默认分区和偏移量(P0,O0)上的数据,还是将它写入分区上的下一个可用偏移量?在kafka上写同一主题

回答

0

它不会被覆盖。请参考文档这里Kafka Topics

简要交代

卡夫卡的作品与pub-sub机制,这意味着出版商将数据发送到一个主题,可以有多个它们。数据将被写入当前偏移量,并且正在阅读该主题的任何订阅者将根据消费者偏移量给出数据。根据所需时间间隔或文件大小的配置,数据将保存在kafka群集的磁盘中。

相关问题