如何在application.yml文件中配置多个kafka使用者
实际上我有一个基于springboot的微服务，并且我已经使用kafka从不同的系统产生/消费数据。现在我的问题是,我有两个不同的主题,根据主题,我有两个不同的消费者类来消费数据,
如何在application.yml文件中定义多个使用者属性？
我在application.yml中为一个使用者配置如下：-
spring:
kafka:
consumer:
bootstrapservers: http://199.968.98.101:9092
group-id: groupid-QA-02
auto-offset-reset: latest
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
我正在我的消费者类中使用@kafkalistener
我在代码@kafkalistener中使用的使用者方法的示例（topics=“${app.topic.b2b_tf_ta_req}”，groupId=“${app.topic.groupoid}”）public void consumer（字符串消息）引发异常{
}
共有1个答案
据我所知，bootstrap-servers接受逗号分隔的服务器列表，即如果您将其设置为Server1:9092、Server2:9092kafka应该连接到所有服务器
-
注意：它在src/main/resources/application.yml中工作
-
我是新的詹金斯，我有一个詹金斯的工作，有两个配置文件。我想定期安排这项工作，例如第一个配置文件运行在晚上8点，第二个在晚上10点。请指教。
-
问题内容： 我正在使用selenium，并想为3个不同的脚本使用单独的firefox配置文件。这可能吗？ 问题答案： 不确定如何执行脚本，但是在实例化对象时，可以指定a 作为参数。这是通过创建一个对象（下面的示例）并提供目标配置文件的路径作为参数来完成的： 据我所知，您无法在实例化实例后修改配置文件（尽管我可能是错的- 如果您需要这样做，值得尝试：））。在这种情况下，您将在每个脚本中创建一个配置文
-
我有一个spring boot kafka客户端应用程序，其中有两个消费者在kafka中收听不同的主题和不同的消费者群。 为了实现，我需要下面有两个JAAS会议(使用不同的keytab文件) dc-jaas-A.conf文件 dc-jaas-B.conf 由于下面的connect tFactory在System.setProperty中设置dc-jaas-A.conf和dc-jaas-B.conf
-
当我试图创建主题时，在执行主题命令replication Factor：1大于可用代理:0时，使用kafka
-
问题内容： 我是一名学习Kafka的新学生，在了解多个消费者（到目前为止，文章，文档等对他们没有太大帮助）方面，我遇到了一些基本问题。 我尝试做的一件事是编写我自己的高级Kafka生产者和消费者并同时运行它们，将100条简单消息发布到某个主题，然后让消费者检索它们。我已经成功地做到了这一点，但是当我尝试引入另一个使用者来使用与刚刚发布消息的主题相同的主题时，它没有收到消息。 据我了解，对于每个主题