仅使用spring cloud stream kafka streams绑定器自动创建生产者主题
是否可以在application.yml中只为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题？我希望我的制片人只负责创造话题。我正在使用spring-cloud-streams和kafka-streams绑定器。
从更广泛的意义上说，这是创建Kafka主题的正确方法吗？
共有1个答案
它是一个绑定器，不是绑定，所以，不。
但是，您可以使用multi-binder支持，并根据需要定义2个具有该属性设置的kafka Binder，一个用于生产者，另一个用于消费者绑定。
https://docs.spring.io/spring-cloud-stream/docs/3.0.10.release/reference/html/spring-cloud-stream.html#多重绑定器
我建议您在针对绑定器的GitHub问题中打开一个新的特性建议，允许在绑定级别重写绑定器属性。
https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issures
-
我有一个消费者作为生产者消费者模式的一部分： 简化： 如果我移除 通过将线程设置为睡眠，CPU使用率攀升到极高的水平（13%），而不是0%。 此外，如果我实例化该类的多个实例，则每个实例的CPU使用率都会以13%的增量攀升。 大约每分钟（可能每30秒）都会向BlockingCollection添加一个新的LogItem，并将适用的消息写入文件。 有没有可能线程以某种方式阻止了其他线程的运行，而系统
-
下面是代码，我面临的问题是recordRead变量告诉线程应该从哪里开始读取记录的起点。但是我如何为每个线程设置不同的值？例如，对于thread1，它应该是0，recordsToRead应该是300，对于thread2，recordsToRead应该是300+300=600，对于最后一个线程，它应该是600以及更高的结束。pagesize=50pagesize、recordRead和recordT
-
我尝试通过wsimport命令生成此命令。下面是我使用的命令。 wsimport-keep-b bindings.xml-p com.aasc.carrier.shipexec.proxy-implserviceName wcfSoxContract-importname wcfShip http://shipexec.com/demo/wcf/soap?wsdl-b-xautonameresol
-
从这篇文章https://www.confluent.io/blog/transactions-apache-kafka/ 使用为至少一次交付语义配置的vanilla Kafka生产者和消费者，流处理应用程序可能会以以下方式完全丢失一次处理语义： 制片人。由于内部重试，send（）可能导致重复写入消息B。这是由幂等生产者解决的，而不是本文其余部分的重点 2.我们可能会重新处理输入消息A，导致重复的
-
我正在用Springboot做一个简单的Kafka示例项目，我遇到了一个错误，制作人没有创建，但其余的工作正常。 我遇到的错误似乎引发了异常，因为制作人没有创建，但没有解释原因，我也不知道： 这是我的kafka配置： 这里是控制器，endpoint“/api/kafka”：
-
我有一个kafka streams应用程序 或 这是一个类，用于将消息分发到不同的分区，即使在kafka 2.4版本中使用相同的键 RoundRobinPartitioner具有以下实现： 我的分区器由完全相同的代码组成，但分区方法实现不同，我的代码块是： 当我这样配置时，消息在两种实现中都被分发到不同的分区，但决不使用某些分区。 我有50个分区，而分区14和34从未收到消息。我的分区不是没有价值