Apache Kafka - 如何等待订阅完成

Question

我正在使用 Kafka 2.1.0，并希望在订阅完成后发布一条消息。生产者有没有办法知道订阅是否发生然后发布消息？否则我每次都会丢失第一条消息。

Answer 1

来自https://kafka.apache.org/documentation.html#newconsumerconfigs、auto.offset.reset 声明：

当 Kafka 中没有初始偏移量或当前 服务器上不再存在偏移量（例如，因为该数据 已删除）：

earliest：自动将偏移量重置为最早的偏移量

latest：自动将偏移量重置为最新的偏移量

none：如果没有找到先前的偏移量，则向消费者抛出异常 对于消费者群体

其他：向消费者抛出异常。

auto.offset.reset 的默认值为latest。为确保您的消费者不会丢失第一条记录，您需要将auto.offset.reset 设置为earliest。