当我使用ConcurrentKafkaListenerContainerFactory时，如何设置主题？
当我使用concurrentKafkaListenerContainerFactory时，有什么方法可以设置主题吗？我根本不想做任何注释。
共有1个答案
如果你不打算使用@KafkaListener，你不需要担心那个工厂。目标ConvoltKafkaListenerContainer对你来说已经足够了。
您可以在那里找到ContainerProperties进行配置。
-
我使用的是Spring Kafka 2.2.7，我已经将配置为，并使用消费消息，一切都按预期运行。 我想添加一个来记录所有消耗的消息，但发现很难配置它。留档指出可以在容器上设置RecordInterceptor，但我不确定如何获取容器的实例。 从版本2.2.7开始，您可以向侦听器容器添加RecordInterceptor；它将在调用允许检查或修改记录的侦听器之前被调用。 我查阅了Spring文档，
-
我正在使用JPA类创建数据库。 如果我们有许多对一个关系，我们可以重写ForeignKey name name，如下所示： 以DB为单位，我们会有这样一个结果： 我使用这个版本的JARS： 我的java版本是1.8
-
我想使用“jdeps”命令来分析一些jar文件的依赖关系。我的操作系统是Windows10。核心代码是 我的计算机中有2个JDK版本，JDK11和JDK8。我想使用JDK11，我将环境变量JAVA_HOMEJDK11的路径。当我使用cmd windows执行代码时，它可以按照我想要的方式工作，但是如果我在Intellij Idea中运行它，JDK将更改为JDK8。 我确定我已经把项目设置-项目-项
-
我已经将enable.auto.commit设置为true，并将auto.commit.interval.ms设置为10,000（即10秒）。现在我的问题是--如果使用者在第一次轮询时得到100条记录，而监听器正在处理一条一条的记录，而它在10秒内只处理了80条记录，它是提交并将偏移提前80还是100？
-
问题内容： 是否引用ListView 或列表中选择的特定项目？ 问题答案： 相信是指整体。要为项目添加点击处理程序，您想使用AdapterView.setOnItemClickListener。
-
我正在使用spring-kafka-2.2.7。RELEASE并尝试在方法级别使用@KafkaListener与ConvoltKafkaListenerContainerFactory一起创建一个消费者。根据我的理解，这将创建一个ConvoltMessageListenerContainer。 > 如果我有两种不同的方法使用@KafkaListener来消费两个不同的主题，它会创建两个Contop