Spring kafka多消费者结果组合
Spring Kafka是一个基于Spring Framework的开源项目，它提供了与Apache Kafka集成的功能。Apache Kafka是一个分布式流处理平台，用于构建高性能、可扩展的实时数据流应用程序。
在Spring Kafka中，多消费者结果组合是指多个消费者协同工作以处理来自Kafka主题的消息，并将它们的结果组合在一起。这种方式可以提高系统的吞吐量和可伸缩性。
多消费者结果组合的优势包括：
- 提高系统的并发处理能力：通过将消息分发给多个消费者并行处理，可以提高系统的并发处理能力，加快消息处理速度。
- 增加系统的可伸缩性：通过增加消费者的数量，可以轻松地扩展系统的处理能力，以适应不断增长的消息负载。
- 提高消息处理的容错性：当一个消费者发生故障时，其他消费者可以继续处理消息，确保系统的稳定性和可靠性。
多消费者结果组合适用于以下场景：
- 实时数据处理：当需要实时处理大量的数据流时，多消费者结果组合可以提供高吞吐量和低延迟的消息处理能力。
- 分布式计算：当需要将计算任务分发给多个消费者并将结果合并时，多消费者结果组合可以提供分布式计算的能力。
- 大规模系统：当系统需要处理大量的消息并具有高可伸缩性时，多消费者结果组合可以帮助实现系统的水平扩展。
在腾讯云的产品中，推荐使用的相关产品是腾讯云消息队列 CKafka。CKafka是腾讯云提供的高可靠、高吞吐量的消息队列服务，与Apache Kafka兼容。您可以通过腾讯云CKafka来实现Spring Kafka多消费者结果组合的需求。
腾讯云CKafka产品介绍链接地址：https://cloud.tencent.com/product/ckafka
相关·内容
这就是场景:我知道，使用与Spring相关的最新API (比如kafka 2.10)，我们可以这样做：
@KafkaListener(id = "id0", topicPartitions = { @TopicPartition(topic = "SpringKafkaTopic", partitions = { "0" }) })
@KafkaListener(id = "id1", topicPartitions = { @TopicPartition(topic = "SpringKafkaTopic",
浏览 0提问于2017-04-17得票数 1
在Spring Boot项目中使用Spring for Apache Kafka时，有没有办法通过application.properties中的条目配置不同的侦听器 例如，如果我在主题foo和bar上有不同的监听程序，我是否可以有如下条目： spring.kafka.producer.foo.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer
spring.kafka.producer.bar.value-serializer=some.other.Serializer 我想我在什么地方看
浏览 30提问于2020-03-29得票数 0
我想知道spring boot内部的spring kafka Producer是否保证交付。
有人知道如果某个随机监听器无法接收消息会发生什么情况吗？spring kafka是否会重试发送消息？
浏览 0提问于2019-05-29得票数 0
我是卡夫卡的新手，我想要帮助
我有两个应用程序(springboot)，它们是相同的/拷贝只有不同的端口。
他们都是消费者
这两个人听XXX这个话题
我有另一个应用程序扮演制片人的角色。
每当我给某某话题发东西。
只有其中一个使用消息，而另一个不使用消息。
我分别测试了两种方法，如果他们是单独听的话，他们也会正常地听，但是如果他们在一起听，只有一人会听。
我在用
<dependency>
<groupId>org.springframework.cloud</groupId>
<a
浏览 0提问于2021-07-06得票数 1
回答已采纳
1回答
我有两个弹簧引导应用程序。我试图映射到application.properties文件中，这样消费者就可以接收生产者发送的消息。我想补充一下，我使用的是一个CustomMessage：
public class CustomMessage {
private LocalDateTime timestamp;
private Integer sensor_id;
private Double measurement_value;
// getters and setters
}
我的生产者的application.properties文件：
# other propertie
浏览 2提问于2021-12-02得票数 2
回答已采纳
是否可以在application.yml中仅为应用程序生成的主题启用spring.cloud.stream.kafka.streams.binder.auto-create-topics，而不是自动创建应用程序使用的主题？我希望我的制作人只负责创建主题。我正在使用spring-cloud-stream和kafka-streams绑定器。 在更一般的意义上，这是创建kafka主题的正确方法吗？
浏览 30提问于2020-11-24得票数 0
回答已采纳
我查看了这些文档，发现如下：
spring.kafka.producer.properties.spring.json.type.mapping=cat:com.mycat.Cat,hat:com.myhat.Hat
我的制片人的财产：
spring.kafka.producer.bootstrap-server=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-seriali
浏览 4提问于2022-09-16得票数 0
回答已采纳
1回答
我对Kakfa Spring集成非常陌生。我已经实现了卡夫卡的信息发送和一个听众，它的工作对我很好。但我想在两个地方听同样的信息。有人能帮我吗。下面是我的密码。
spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.consumer.auto-commit-interval=100
spring.kafka.consumer.bootstrap-servers=localhost:9092
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.gr
浏览 5提问于2017-03-02得票数 1
回答已采纳
1回答
我经历了以下两个环节：
它们都有两种不同的方法，最多只能实现一次消费者语义，所以我有点搞不懂该遵循哪一种方法。
我当前的使用者配置是：
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.bootstrap-servers=<server port>
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization
浏览 0提问于2020-08-17得票数 0
1回答
Camel JMS组件多线程
、、、、
我有一个spring boot应用程序，使用Camel的jmsComponent处理来自多个Solace队列的消息。我为每个队列连接定义了一个Camel route，并定义了一个将消息转换为json的Camel Processor。有大量来自队列的消息，而我的程序无法跟上速度。 路由： @Component
public class SomeRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("jms:{{queue.name}}&
浏览 22提问于2020-07-21得票数 1
所以基本上我看到的是，我正在使用@KafkaListener消费消息，我故意不想承认它们，所以消费者忽略它们，并在主题中侦听新的消息。因此，如果应用程序重新启动，使用者只会从最后提交的消息开始。因此，我希望避免这种情况，我希望消费者在不重新启动的情况下考虑未提交的消息。下面是我正在使用的配置和@kafkalistener。
ReceiverConfig.java
package com.config;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serializ
浏览 3提问于2019-12-05得票数 1
如果Kafka (spring.cloud.stream.bindings..producer.partitionCount)大于1并且Kafka (spring.cloud.stream.bindings..consumer.partitioned)为false，会发生什么情况(使用partitionCount )
浏览 28提问于2021-05-08得票数 0
回答已采纳
1回答
我使用kafka和spring引导应用程序在阅读完主题消息后使用消息，我将收到此错误。
2020-07-07 17:05:32,265 INFO GroupCoordinator 1001:组员consumer-1-708fe639-905d-432a-b6ba-17bf58adcf03 -service-prod已经离开，从小组(kafka.coordinator.group.GroupCoordinator) 2020-07 17:05:32,267 INFO GroupCoordinator 1001:准备重新平衡团体自行车-服务-prod在州与老一代460 (_消费者_偏移-7)(理
浏览 3提问于2020-07-07得票数 2
回答已采纳
1回答
我正面临一个奇怪的问题，在卡夫卡，所有的卡夫卡消息，从主题正在重放消费者应用程序重新启动。有人能帮我吗我在这里做错了什么？
这是我的配置：
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.enable.auto.commit=假
我的生产者配置：
producerconfigs.put(ENABLE_IDEMPOTENCE_CONFIG, "true");
producerconfigs.put(ACKS_CONFIG, "all");
p
浏览 4提问于2021-04-01得票数 1
我使用Spring Boot 2.0.7和Spring-Kafka来创建请求/应答模式。基本上，前端UI向API发出请求，API将消息放到请求Kafka队列中，消息由后端进程处理，完成后将消息放到应答队列中。
我想提供的前端用户界面的api，等待，直到响应准备就绪。此时的UI将仅显示一条正在处理的消息。如果响应不可用(例如，2分钟后)，API应该只返回消息不可用错误，我们可以指示用户稍后再来。
我是Spring-Kafka的新手。它允许我创建一个轮询API吗？如果是这样的话，任何示例代码都将非常感谢。
浏览 1提问于2018-12-08得票数 0
1回答
弹簧靴卡夫卡手册失败
、、、
我有一个Spring消费者的下面的配置。我在尝试手动确认而不是自动提交。在手动确认后，我开始出错。Spring版本为2.7.2。
kafka.consumer.groupId=mcs-ccp-event
message.topic.name=mcs_ccp_test
kafka.bootstrapAddress=kafka-dev-app-a1.com:9092
spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE
和这种使用者配置
@EnableKafk
浏览 26提问于2022-08-06得票数 0
回答已采纳
我有一个@StreamListener方法，它将执行REST调用。当REST调用返回异常时，@StreamListener方法抛出RunTimeException并重试。@StreamListener方法抛出RuntimeException时，重试次数不限
Spring云流重试配置：
spring.cloud.stream.kafka.bindings.inputChannel.consumer.enableDlq=true
spring.cloud.stream.bindings.inputChannel.consumer.maxAttempts=3
spring.cloud.stream.
浏览 0提问于2018-08-27得票数 1
我正在尝试使用Kafka-Spring (spring-boot)实现一个Kafka消费者。我使用生产者发送了一条消息，但是Spring抛出了一个异常，并且由于这个异常，我的侦听器方法没有被调用。
下面是我的监听器方法：
@Service
public class KafkaExchangeApi {
@KafkaListener(topics = ORDER_TOPIC, groupId = "group_id")
public void handleOrderResponse(@Payload GatewayOrder response) {
浏览 0提问于2020-09-10得票数 1
我目前正在使用Kafka listener设置一个Spring Boot应用程序。我正在尝试只对消费者进行编码。对于producer，我目前在Kafka控制台手动发送消息。我遵循了下面的示例：
我尝试将其作为Spring Boot应用程序运行，但无法看到收到的任何消息。在我的本地Kafka主题中已经有一些消息了。
C:\software\kafka_2.11-0.10.1.0\kafka_2.11-0.10.1.0\kafka_2.11-0.10.1.0\bin\wind
ows>kafka-console-producer.bat --broker-list localhost:909
浏览 3提问于2017-01-04得票数 4
我想在向kafka topic发出消息后，获取偏移量和分区信息。我通读了spring cloud stream kafka绑定文档，发现这可以通过使用RECORD_METADATA kafka头来实现。
来自Spring文档：()
recordMetadataChannel成功发送结果应发送到的MessageChannel的bean名称；该bean必须存在于应用程序上下文中。发送到通道的消息是具有附加标头KafkaHeaders.RECORD_METADATA的已发送消息(转换后，如果有)。头部包含一个由Kafka客户端提供的RecordMetadata对象；它包括在主题中写入记录的分区和偏移
浏览 0提问于2020-09-23得票数 1
我有一个带有Kafka应用程序的Springboot，我的Kafka集群从docker文件开始。但是，如果Kafka集群保持启动，但是Spring应用程序重新启动，则无法接收任何消息(函数正常工作)。
属性文件：
server.port=18080
spring.kafka.bootstrap-servers=localhost:29092,localhost:39092
spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.cons
浏览 8提问于2022-05-31得票数 0
我有一个spring boot应用程序，我想将一个Kafka主题的负载分布到3个open-shift pod中。我有下面的例子，我可以在三个不同的线程上监听3个Kafka分区，这个spring boot应用程序将加载到一个openshift pod中。但我希望能够在一个pod上从一个Kafka分区监听，这样当我在open-shift上加载3个pod时，每个pod将从一个Kafka分区监听。这将允许我将应用程序扩展到N个pod上的N个分区。我不确定这是否可能，或者是否需要使用不同的方法。谢谢
public class DepAcctInqConsumerController {
p
浏览 0提问于2021-03-11得票数 1
我正在使用教程尝试基本的spring引导卡夫卡应用程序。
我的项目层次如下：
SpringBootKafkaApplication.java
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SpringBootKafkaApplication{
public static void main(String[] ar
浏览 5提问于2019-10-17得票数 1
我是卡夫卡的新手。我正在开发Spring-Kafka POC。我们的KAFKA服务器是Kerberized的。有了所有必需的配置，我们就能够访问Kerberized化的Kafka服务器了。现在我们有了另一个需求，我们必须使用来自非Kerberized(简单Kafka消费者) Kafka服务器的主题。我们可以在单个应用程序中通过创建另一个具有自己的侦听器的KafkaConsumer来做到这一点吗？
浏览 10提问于2017-08-07得票数 1
我有一个使用Spring Cloud Stream编写的Kafka消费者，它连接到部署在Amazon MSK集群上的Kafka，并使用秘密管理器进行定期密码轮换。 问题： 我是否需要在每次密码轮换时重新实例化应用程序？如果是，有没有使用Spring Cloud Stream的标准方法？ 当前的解决方案:我们已经实现了一个基于Spring执行器的健康检查。在活页夹连接失败的情况下，我们重新启动ECS。 当前的解决方案非常不稳定，因为我们仍然会遇到SASLAuthentication异常，运行状况检查没有捕获到该异常，也没有重新实例化应用程序 请给我建议一条出路。
浏览 67提问于2021-11-08得票数 0
我正在使用spring chained transection设置kafka横截面管理器，并且我必须在Spring Kafka (Spring Boot版本1.5.18和spring Kafka版本1.3.8)中设置isolation.level = read_committed作为消费者属性，但无法找到任何方法来设置它。
浏览 92提问于2019-05-04得票数 0
回答已采纳
Spring Boot: 2.0.3版本 org.apache.kafka.kafka-streams: 1.0.0 Org.apache.kafka.kafka-客户端: 1.0.0 org.springframwork.kafka:spring-kafka-test:2.1.7.RELEASE 我有一个使用Kafka的Spring启动应用程序。我正在尝试使用https://blog.mimacom.com/testing-apache-kafka-with-spring-boot/来创建一个集成测试。 当我添加@EmbeddedKafka注解时，我在运行 org.springframew
浏览 92提问于2019-04-30得票数 0
回答已采纳
在spring引导应用程序中，我正在设置一个kafka侦听器，而且我似乎无法使用执行器在池中运行侦听器。这是我的kafka配置：
@Bean
ThreadPoolTaskExecutor messageProcessorExecutor() {
logger.info("Creating a message processor pool with {} threads", numThreads);
ThreadPoolTaskExecutor exec = new ThreadPoolTaskExecutor();
exec.setCorePoolSiz
浏览 1提问于2017-08-03得票数 3
回答已采纳
我用的是卡夫卡和flink。在一个简单的程序中，我使用flink FlinkKafkaConsumer09，将组id分配给它。
根据Kafka的行为，当我使用相同的group.Id在同一主题上运行两个消费者时，它应该像消息队列一样工作。我认为这应该是这样的:如果向Kafka发送2条消息，那么flink程序中的每条或一条将处理这2条消息完全两次(假设总共有2行输出)。
但是实际的结果是，每个程序将接收2条消息。
我尝试使用随kafka服务器下载的消费者客户端。它以记录的方式工作(处理了2条消息)。
我试图使用两个卡夫卡消费者在相同的主要功能的flink程序。共处理4条信息。
我还试着运行两个fl
浏览 10提问于2016-07-28得票数 6
回答已采纳
这不是一个大问题，但我很好奇，一些额外的流消费者来自哪里，如果这是一个设置，我可以改变。
我有一个非常简单的spring云流消费者设置，针对当地的Kafka代理。这是spring的配置
spring:
cloud:
stream:
bindings:
consumer-in-0:
destination: test-topic
group: test-group
而消费者阶层本身：
@Bean
Consumer<Message<String>> consumer() {
return me
浏览 7提问于2021-04-14得票数 0
回答已采纳
1回答
Kafka未连接到下面的问题
、、、、
2021-09-09 21:42:40.039 WARN 14636 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-mygroup-1, groupId=mygroup] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
2021-09-09 21:42:40.039 WARN 14636 ---
浏览 7提问于2021-09-09得票数 1
类似于：
我在微服务器架构中启动batch时做了一个poc，我正在使用Spring batch和Spring Cloud Stream Kafka。我正在寻找一种方法来动态创建消费者(处理器)应用程序的多个实例。我看到可以使用以下命令定义许多实例
spring.cloud.stream.instanceCount=n
spring.cloud.stream.instanceIndex=[0, ..., n-1]
但是，我还没有找到一种动态更改instanceIndex值的方法。是否可以使用Spring Cloud Stream kafka动态修改此值。
谢谢你的帮助。
浏览 6提问于2021-05-08得票数 5
我正在实现spring批处理侦听器，它读取kafka主题的消息列表并将数据发布到REST服务。我想了解在REST服务下降时的偏移管理，批处理的偏移量不应该提交，下一次轮询的消息应该被处理。我已经阅读了spring文档，但在理解侦听器错误处理程序和在批处理中寻求当前容器错误处理程序之间的区别方面存在混淆。我使用的是spring 2.0.0.M7及以下版本是我的代码。
Listener Config:
@Bean
KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>
浏览 2提问于2017-12-13得票数 0
1回答
我没有看到使用执行器/actuator/metrics.的卡夫卡消费者/生产者指标。只显示了基本的jvm指标。
{
"names": [
"jvm.buffer.memory.used",
"jvm.threads.states",
"jvm.memory.committed",
"spring.integration.channels",
"process.uptime",
"jvm.memory.used",
"jvm.gc.pause",
"logbac
浏览 6提问于2020-07-06得票数 1
回答已采纳
我在努力学习卡夫卡+斯普林普靴。我想在我的使用者类中添加第二个使用者，它订阅与第一个主题相同的主题，但是有一个不同的groupID。类不是很复杂，只有第一个消费Json的使用者(或者至少输出是Json?)时才能工作。另外，为了解释一下，我开始时只使用了一个生产者和使用者，他们使用的是@EnableBindings方法，但是它是不推荐的，所以我正在学习正确/新的方法。
任何小费都可以！请让我走上正确的道路。
我有很多Maven依赖项，所以我只想总结一下:它包括spring、kafka-streams、spring starter jpa等等.
应用程序属性，我不确定底部的headers属性是否正
浏览 12提问于2022-04-20得票数 0
2回答
通过使用Spring的微服务应用层，当一个服务将一条消息发布到kafka主题中时，使用该消息的另一个服务就会关闭。当它返回时，它会从停止的地方重新处理吗？为了不丢失任何消息，需要进行一些设置吗？其主要思想是将该消息作为流处理。
浏览 0提问于2018-01-08得票数 0
1回答
我需要访问spring云流kafka事务性重试中的重试尝试号，这样对于特定的异常，基于重试尝试号，我可以将结果发布到不同的主题。
浏览 3提问于2022-09-27得票数 1
回答已采纳
我使用的是spring kafka，我想知道kafka消费者什么时候会被驱逐出群。当处理时间超过轮询间隔时，它会被逐出吗？如果是，那么心跳的目的不是表明消费者是活的，如果发生这种情况，那么消费者永远不应该被驱逐，除非进程本身失败。
浏览 1提问于2020-05-22得票数 0
我得到了一个意外的场景，一个Kafka主题的所有订阅者( Spring应用程序)都没有得到Spring配置更改刷新通知。只有一个拥有Kafka分区的订阅者获得刷新通知。没有为其他订阅者分配Kafka分区，也没有获得刷新事件。
浏览 3提问于2022-03-21得票数 0
1回答
我有生产者，它产生一些消息(例如10)。有n个分区和一个包含n个消费者的消费者组。Kafka系统将消息分发到消费者之间。我如何将所有消费者的消息组合在一个地方，以便我有10条消息。我使用的是Kafka和Spring。
浏览 10提问于2019-02-10得票数 0
我遇到了这样的情况，我想暂停消费者停止通过spring boot应用程序消费消息，并且消息不应该从队列中丢失，我正在使用amqp和spring cloud stream。 https://github.com/spring-cloud/spring-cloud-stream/blob/master/docs/src/main/asciidoc/spring-cloud-stream.adoc#binding_visualization_control声明只有kafka有这个选项。 我能为rabbit mq活页夹做些什么吗？
浏览 44提问于2019-03-31得票数 0
我查看了这些文档，发现如下：
spring.kafka.producer.properties.spring.json.type.mapping=cat:com.mycat.Cat,hat:com.myhat.Hat
我的制片人的财产：
spring.kafka.producer.bootstrap-server=localhost:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-seriali
浏览 27提问于2022-09-16得票数 0
回答已采纳
使用spring- Dalston.SR4运行spring引导的Dalston.SR4程序。我通过云流进行了研究，特别是关于kafka绑定器的使用，但在一些配置方面还不清楚：
当我们从卡夫卡经纪人那里消费时，我们真的需要设置spring.cloud.stream.{instanceCount,instanceIndex}吗？考虑到设置了spring.cloud.stream.bindings.<channel>.group，我不明白为什么需要这样做。还是说只有在cloud.stream.kafka.bindings.<channel>.autoRebalanceEn
浏览 2提问于2017-10-13得票数 0
回答已采纳
我有一个spring boot应用程序。我希望实现一个从Kafka主题消费的函数，对于每个消费的消息，它调用另一个方法对消息进行一些处理，然后将其存储在数据库中。源kafka主题有12个分区。我想在同一个消费群体下创建6到12个kafka消费者。所有的消费者都将消费来自Kafka的消息并调用该函数。我不能得到一个好的设计。有人能帮帮我吗？
浏览 1提问于2020-02-19得票数 1
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
使用该配置
使用spring-integration-kafka扩展和以下配置：
<int-kafka:zookeeper-connect id="zookeeperConnect"
zk-connect="#{kafkaConfig['zooKeeperUrl']}" zk-connection-timeout="10000"
zk-session-timeout="10000" zk-sync-time="2000" />
<int-kafka:consume
浏览 0提问于2016-01-29得票数 0
1回答
什么是kafka 0.10.1.1的“kafka 0.10.1.1”
根据文档，它在下显示为“动物园管理员”。
offsets.storage动物园管理员选择应该存储偏移量的地方(动物园管理员或卡夫卡)。
我的消费者是spring-boot-1.5.13 RELEASE应用，它在内部使用kafka-clients-0.10.1.1。根据源代码，offsetStorage是“动物园管理员”，但当我运行使用者时，我看到"__consumer_offsets“是在server.properties即代理定义的/tmp/kafka-logs目录下创建的；
而且，当我使用zookeepe
浏览 0提问于2018-07-14得票数 1
回答已采纳
2回答
我正在使用spring boot + spring @KafkaListener。我期望的行为是:我的kafka侦听器在10个线程中读取消息。因此，如果其中一个线程挂起，其他消息将继续读取和处理消息。
我定义了的bean
@Bean
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(
ConcurrentKafkaListenerContainerFactoryConfigurer configurer,
ConsumerFactory
浏览 0提问于2019-11-16得票数 6
回答已采纳
我已经设置了一个Spring Boot应用程序来接收来自现有的和工作的Kafka生产者的Kafka消息。该设置是标准的，并基于以下内容：
不会收到消息，控制台会持续显示以下内容：
WARN org.apache.clients.NetworkClient :Bootstrap broker <hostname>:9092 disconnected
此外，还会记录以下调试消息：
org.apache.common.errors.Timeout: Failed to update metadata after 60000 ms.
控制台消息在以下链接中进行了讨论：
此处讨论了记录的消
浏览 11提问于2018-02-09得票数 2
我对Kafka和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个主题，并且消息一到达就被处理。结果会回发到主题或数据库。
Spring Kafka注解@KafkaListener具有相同的功能。例如，我尝试过。在这里，我们也会监听一个主题，并在发布内容时对其进行处理。
所以我很好奇地想知道1.这2个有什么不同? 2.在哪种情况下更喜欢哪一种？
浏览 5提问于2018-01-18得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
