如何为Kafka创建多个消费者

ggazkfy8  于 2023-04-05  发布在  Apache
关注(0)|答案(1)|浏览(282)

我正在努力在Kafka中添加多个消费者。现在只有一个消费者,但如果我想要更多的消费者,有没有一种方法可以通过bash文件添加它们。在这种情况下,kafka消费者在java文件中声明,并通过设置属性声明。我不知道如何在这种情况下通过shell使用属性。提前感谢
我已经尝试在java文件中添加消费者,但我需要通过bash添加它们

qvtsj1bj

qvtsj1bj1#

通过bash
使用&将进程发送到后台
例如:在同一个消费者组中创建2个消费者

kafka-console-consumer --topic foo --group bar ... &
kafka-console-consumer --topic foo --group bar ... &

本例中的Kafka消费者是在Java文件中声明的
然后多次运行Java进程

java jar app.jar &
java jar app.jar &

或者,使用threads. https://github.com/confluentinc/parallel-consumer
不确定如何通过shell使用属性
您可以使用String[] args在Java代码中提取文件名,然后将其作为参数传递给代码。

java jar app.jar app.properties &
java jar app.jar app.properties &

相关问题