春云流（Kafka）自动创建视图不起作用
spring.cloud.stream.kafka.binder.auto-create-topics=false
2021-06-25 09:22:46.522 INFO 38879 --- [pool-2-thread-1] o.a.k.clients.consumer.ConsumerConfig : ConsumerConfig values:
allow.auto.create.topics = true
auto.commit.interval.ms = 5000
auto.offset.reset = latest
bootstrap.servers = [localhost:9092]
-
null
我在这个配置中缺少什么吗？
共有1个答案
spring.cloud.stream.kafka.binder.auto-create-topics=false
该属性配置活页夹，使其不会创建主题；它不设置该使用者属性。
若要显式设置该属性，请将
spring.cloud.stream.kafka.binder.consumer-properties.allow.auto.create.topics=false
-
现在我正在尝试用kafka创建消息服务功能以使用< code > spring-cloud-stream-bind-Kafka ，但效果不太好。 Spring罩1.4.2 当我使用此错误日志启动项目时失败 我在怀疑我的春靴版本。这么低配的版本。< br >我认为< code > spring-cloud-stream-binder-Kafka 在spring boot 2.0版本下无法使用或者其他
-
我用的是Apache Kafka 2.7.0和Spring Cloud Stream Kafka Streams。 在我的Spring Cloud Stream (Kafka Streams)应用程序中，我已经将我的application.yml配置为当输入主题中的消息出现反序列化错误时使用sendToDlq机制: 我启动了我的应用程序，但我看不到这个主题存在。文档指出，如果 DLQ 主题不存在，
-
Spring Cloud Kafka Streams与Spring Cloud Stream、Spring Cloud Function、Spring AMQP和Spring for Apache Kafka有什么区别？
-
由于某些原因，我的位图创建不起作用。我找到一只虫子了吗？当我尝试使用矩阵创建一个新位图时，它说我的宽度和高度必须大于0，这毫无意义。 我知道这看起来好像我没有做过任何研究，我做过，但这没有意义。我已经尝试了很多事情，包括将新宽度和新宽度更改为常量，但它仍然不起作用。如果有帮助的话，这是堆栈跟踪 我正在尝试制作一个旋转门户。我想有一个矩阵平移，旋转和缩放，但我没有得到工作。我决定把译文拿出来，只是做
-
我正试图按照GitHub的建议设置测试 其中StreamProcessor设置为 -->line从不使用在我看来应该在主题“output”上的消息，因为@StreamProcessor有@Sendto（“output”） 我希望能够测试流处理的消息。
-
我需要从配置文件动态创建kafka流，其中包含每个流的源主题名称和配置。应用程序需要有几十个Kafka流和流将是不同的每个环境（例如阶段，prod）。它可能做到这一点与库？ 我们可以通过轻松做到这一点： 我们需要实现spring接口，这样所有流都将自动启动和关闭。 是否可以使用做同样的事情？正如我所看到的，我们需要在代码中创建每个Kafka流，我看不到如何使用创建Kafka流列表的可能性。 但是如