学习spring-cloud-stream-binder-kafka

问题描述这是question的续集。我可以把"普通"的阿帕奇卡夫卡活页夹和功能模型一起使用吗？到目前为止，使用基于注释的配置，我在一个应用程序中混合了spring-cloud-stream-binder-kafka和spring-cloud-stream-binder-kafka

问题描述我将SpringCloudStreams与KafkaStreams绑定器一起使用，功能样式处理器API和多处理器。以这种方式配置一个具有多个处理器和多个Kafka主题的处理应用程序，并使用/Actuator、WebClient等方式保持在SpringBoot领域，这真的很

问题描述我正在使用SpringCloudStream处理KafkaStreams.在消息处理应用程序中，有可能会产生错误.所以消息不应该被提交并再次重试.IamworkingonKafkaStreamsusingSpringCloudStream.Inthemessageproc

问题描述我们有多个应用程序消费者监听同一个kafka主题，生产者在向主题发送消息时设置消息头，以便特定实例可以评估头并处理消息.例如Wehavemultipleapplicationsconsumerlisteningtothesamekafkatopicandaproducer

问题描述我有一个带有2个主题的SpringBootkafka流应用程序，考虑主题A和B.主题A有16个分区，主题B有1个分区.考虑将应用程序部署在具有num.stream.threads=16.我运行kafka-consumer-groups.bat命令来检查线程如何分配给组中的

问题描述我正在尝试使用KafkaStreams做一个简单的POC.但是，我在启动应用程序时遇到异常.我正在使用Spring-Kafka、Kafka-Streams2.5.1和SpringBoot2.3.5Kafka流配置IamtryingtodoasimplePOCwithKaf

问题描述有没有办法让(SpringCloudStream)应用程序在ConfluentCloud中自动创建他们需要的主题?Isthereawaytoallow(SpringCloudStream)applicationsautocreatethetopicstheyneedinC

问题描述我正在为Kafka试用最新的Spring云流框架.但是，对于String和Double其工作正常，但是当我尝试发送JavaPOJO类时，它会引发以下异常.HiIamtryingoutthelatestSpringcloudstreamframeworkforKafka.H

问题描述我正在关注这个模板用于Spring-cloud-stream-kafka但在使生产者方法transactional时卡住了.我之前没有使用过kafka所以需要帮助以防kafkaIamfollowingthistemplateforSpring-cloud-stream-k

问题描述我打算为Kafka消费者弹性设置多个绑定.更具体地说，备份侦听器与主侦听器具有相同的目标和组，期望代理IP.备份侦听器的自动启动在启动时关闭，但会在发生故障转移时以编程方式打开.IintendtosetupmultiplebindingsforKafkaConsumerr