【发布时间】:2017-12-30 09:49:18
【问题描述】:
在使用 confluent-kafka-dotnet v0.9.5 上的 ProduceAsync 方法写入 Kafka 上的同一主题时,它会覆盖默认分区和偏移量(P0,O0)上的数据还是写入下一个可用偏移量在分区?
【问题讨论】:
标签: c# apache-kafka kafka-producer-api confluent-platform
在使用 confluent-kafka-dotnet v0.9.5 上的 ProduceAsync 方法写入 Kafka 上的同一主题时,它会覆盖默认分区和偏移量(P0,O0)上的数据还是写入下一个可用偏移量在分区?
【问题讨论】:
标签: c# apache-kafka kafka-producer-api confluent-platform
它不会覆盖。请参考这里的文档Kafka Topics
简要说明
Kafka 使用pub-sub 机制,这意味着发布者将数据发送到一个主题,并且可以有多个。数据将被写入当前偏移量,并且从该主题读取的任何订阅者都将根据消费者偏移量获得数据。数据将根据所需时间间隔或所需文件大小的配置保留到 kafka 集群中的磁盘。
【讨论】: