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