泉云流Kafka制作人，制作动感Kafka主题
我想使用spring cloud stream framework创建一个kafkaendpoint，它将有一个http post api到/{topic_name}。如何动态更改spring.cloud.stream.bindings.
属性
我可以使用Confluent Kafka REST Proxy实现来实现上述功能，但不知道是否有可能在Spring中开发此功能。
共有1个答案
下面的示例演示了这些类型的用例，在这些用例中，它使用基于http触发器的动态目的地。看一下代码和自述文件。
https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/source-samples/dynamic-destination-source-kafka
-
我正在考虑创建一个独立的Kafka生产者，它作为守护进程运行，通过套接字接收消息，并将其可靠地发送给Kafka。 但是，我决不能是第一个想到这个想法的人。这样做的目的是避免使用PHP或Node编写Kafka生成器，而只是通过套接字将消息从这些语言传递到独立的守护进程，这些语言负责传递，而主应用程序则一直在做自己的事情。 此守护进程应负责在发生中断时进行重试传递，并充当服务器上运行的所有程序的传递点
-
我想让我的Kafka制作人变得富有交易性。我正在发送10条消息。如果发生任何错误，则不应向Kafka发送任何消息，即无或全部。 我使用的是Spring Boot KafkaTemplate。 我正在发送文件中提到的10条信息，如下所示。应发送9条消息，且I消息大小超过1MB，由于 https://docs.spring.io/spring-kafka/reference/html/#using-K
-
假设我有一个主题T1，它有三个分区，即P1、P2和P3。其中p1是领导者，rest是追随者。
-
我正在探索反应性Kafka，只是想确认反应性Kafka是否等同于同步制作人。与同步生产者，我们得到消息传递保证与确认字符和生产者序列保持。但是，ASYNC不能保证交付和测序。反应式生产者等同于SYNC还是ASYNC？
-
我有一个基于camel的应用程序（spring，用XML描述路由）。我希望它能够将输入消息路由到未知数量的Kafka主题（基于文件名模式和主题名称之间的可配置匹配），这样我就无法在xml文件中提前创建每个模式的生产者。 理想情况下，我们应该能够在消息头中设置主题，比如分区id。。。 有人有什么建议吗？
-
我对kafka制作人有问题。实际上我正在使用Spring kafka，并通过KafkaTemboard leke发送消息： 问题是有时发送消息需要 4-20 秒。有很多消息需要 100 毫秒才能发送。所以我有几个问题： > < li> 消息大小和吞吐量之间是否有关联，这种关系是什么？ 我应该首先检查什么，也许我没有很好地调整，任何方向？