我正在努力在Kafka中添加多个消费者。现在只有一个消费者，但如果我想要更多的消费者，有没有一种方法可以通过bash文件添加它们。在这种情况下，kafka消费者在java文件中声明，并通过设置属性声明。我不知道如何在这种情况下通过shell使用属性。提前感谢我已经尝试在java文件中添加消费者，但我需要通过bash添加它们
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代码中提取文件名，然后将其作为参数传递给代码。
String[] args
java jar app.jar app.properties & java jar app.jar app.properties &
1条答案
按热度按时间qvtsj1bj1#
通过bash
使用
&将进程发送到后台例如：在同一个消费者组中创建2个消费者
本例中的Kafka消费者是在Java文件中声明的
然后多次运行Java进程
或者，使用threads. https://github.com/confluentinc/parallel-consumer
不确定如何通过shell使用属性
您可以使用
String[] args在Java代码中提取文件名，然后将其作为参数传递给代码。