SpringKafka与Spring积分Kafka的区别
使用Kafka作为微服务体系结构中的消息传递系统，我想知道哪一个是首选，是Spring Kafka，还是Spring Integration Kafka，为什么？还有，我们根据什么因素来决定选择哪一个？
共有1个答案
Spring Integration-扩展Spring编程模型以支持众所周知的企业集成模式。
Spring Integration Kafka-是Spring Integration项目的扩展模块。
Spring Integration Kafka现在基于Spring for Apache Kafka项目。
-
简单问题： 假设我有一个具有3个分区的主题：Topic：StateEvents P1、P2和P3。 让我们假设生产者生成20条消息： 1, 2, 3, ..........20 我的问题是: 当制作人生成这些消息时： 1）每个消息将只在且仅在1个分区？也就是说，1在P1,2在P2,3在P3，然后4在P1,5在P2,6在P3，以此类推？ 2）如果#1为真，当消费者订阅时，它将订阅所有分区，以便获得所
-
我最近注意到Camel现在有自己的Kafka组件，所以我决定给它一个旋转。 我决定尝试一个很好的简单文件->kafka主题如下...
-
我正在使用OpaqueTridentKafkaSpout来消费来自Kafka的消息。下面是代码。我忽略了配置，因为这会导致同一kafka消息在多个批处理中到达。 当Kafka喷口开始时，我得到以下错误一次，但之后运行平稳。
-
我已经在集群中配置了3个kafka，我正在尝试与sping-kafka一起使用。 但是在我杀死kafka领导者后，我无法发送其他消息到队列。 我将Spring.kafka.bootstrap-servers属性设置为：“kafka-1：9092;kafka-2：9093，kafka-3：9094”以及我的主机文件中的所有名称。 Kafka0.10版 有人知道如何正确配置？ 编辑 我测试过一个东西，
-
求大佬解释下这个结果怎么算出来的？ 如何确定积分的区域呢？
-
我正在使用Kafka生产者发布消息到一些其他Kafka的主题，它的工作相当好。下面的示例模板： 上述语句是否支持kafka消息驱动入站通道适配器中所支持的errorchannel？ 每当我传出的kafka服务器宕机，我无法发布它时，我需要它来审计错误计数。