本文链接:https://blog.csdn.net/jyb199158/article/details/82841731
启动多个logstash并行消费kafka数据。

1.设置相同topic

2.设置相同groupid

3.设置不同clientid

4.input 的这个参数 consumer_threads => 10 多实列相加最好等于 topic分区数

如果一个logstash得参数大于topic,则topic数据都会被这个logstash消费掉

logstash_1

logstash_2

————————————————
版权声明:本文为CSDN博主「林沂梵」的原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/jyb199158/article/details/82841731

发表评论

邮箱地址不会被公开。 必填项已用*标注