在logstash中获得错误后,如何在kafka中回滚偏移?

sgtfey8w  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(265)

我有一个关于logstash错误处理的问题。在我的例子中,我有以下集群:
Kafka->logstash->elasticsearch
据我所知,如果logstash从kafka的主题中读取消息,但无法将其写入elasticsearch,那么它将停止从输入(kafka)中读取。这是否意味着,第一条没有写入es的信息将丢失,因为Kafka的偏移量将被移动?
提前谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题