这是我的代码，第一个bean查看Topic.TRANSACTION_RAW上的消息，将一个消息一分为二并发送到Topic.TRANSACTION_INTERNAL，第二个bean进行分组和还原，并将其具体化到状态存储
浏览 20提问于2021-04-27得票数 0
received") ...
} 然而，我的对象(示例中的Payload)没有正确映射(某些字段为空有没有办法在spring-kafka应用中记录所有传入的kafka KV对？
浏览 7提问于2021-10-15得票数 0
在没有Spring Boot自动配置功能的情况下，是否可以仅将spring-kafka用作配置框架-类似于解析application.properties或application.yaml，并实例化消费者和生产者基本上，只为public static void main应用程序提供了最少的spring和spring-kafka。
谢谢
浏览 12提问于2020-03-04得票数 0
回答已采纳
在Spring-Kafka中使用ProducerFactory，我可以创建一个生产者实例。但是，我想创建三个生产者实例，因为我有三个分区。类似地，我想要三个consumer实例。我如何做到这一点呢？
浏览 2提问于2019-10-25得票数 1
'org.springframework.kafka:spring-kafka'所以我的问题是-如果这两种方法都允许与Kafka交互，
浏览 3提问于2021-11-10得票数 0
回答已采纳
我想使用Spring Kafka将事件处理到本地数据库中，并将偏移量存储在数据库本身中，如“在Kafka之外存储偏移量”下的https://kafka.apache.org/25/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html中所述。 Spring Kafka (带有KafkaListener)似乎总是提交偏移量(因此需要group.id)，有没有办法完全禁用提交，允许在没有组的情况下进行侦听？
浏览 46提问于2020-07-03得票数 1
回答已采纳
我使用spring-kafka来使用SpringBoot1.5.16实现流应用程序。我们使用的spring-kafka版本是1.3.8 version。方法为。我的问题如下。是否有一种简单的方法将UncaughtExceptionHandler注册为bean并让Spring正确地注入到工厂bean中？
浏览 4提问于2020-01-17得票数 1
回答已采纳
1回答
在我的Kafka Listener被击中之前，我得到了一堆反序列化的失败。我正在研究Gary Russel构建的东西，但在让它工作时遇到了问题。我所有的东西都是通过属性文件配置的。 spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
spring.kafka.consumer.properties.spring.deserializer.value.delegate.class=io.confluent.kafka.se
浏览 21提问于2021-01-07得票数 0
回答已采纳
我对Kafka和阅读文档有点陌生。卡夫卡办公网站有一个。其中应用程序被绑定到一个主题，并且消息一到达就被处理。结果会回发到主题或数据库。所以我很好奇地想知道1.这2个有什么不同? 2.在哪种情况下更喜欢哪一种？
浏览 5提问于2018-01-18得票数 1
我正在使用spring-kafka RetryableTopic进行带有固定BackOff和a single retry topic的非阻塞重试。而且如果我使用这个标头： @Header(name = RetryTopicHeaders.DEFAULT_HEADER_ATTEMPTS, required = false) int attempt 127后溢出为0我在spring-kafka文档中找不到max_retries的任何限制，但在source code中我看到它只需要第一个字节。 是bug还是功能？
浏览 174提问于2021-11-05得票数 1
如果将我的spring依赖项更新为2.5.2以上的任何版本，这个问题就会得到解决。例如："addListener“现在摘自Spring-Kafka2.5.3
浏览 5提问于2021-11-29得票数 0
回答已采纳
我已经为消息有效负载设置了自定义标头，并发布了它，但我在消费者端看不到这些标头。
我已经使用消息对象来绑定有效负载和头部。
浏览 130提问于2019-05-24得票数 0
-->Spring Boot (v2.4.7)我在尝试读取来自KAFKA Consumer的消息时遇到问题。我有一个Kafka消费者配置，并得到以下错误 "com.base.employee.dtos.employeeexecution.EmployeeExecutionEBO“-->我的项目中没有这个。"com.base.person.dtos.personexecution.PersonEBO"-->我在我的项目中有这个 | ERROR | [org.springframework.kafka.KafkaListenerEndpointConta
浏览 224提问于2021-10-04得票数 0
spring-kafka : from 2.7.4 to 2.7.7kafka-clientscommon/kafka/utils/Time;Lscala/Option;/Lscala/collection/Seq;)V 根据spring docs https://spring.io/projects/spring-kafkadependency&
浏览 83提问于2021-10-16得票数 0
回答已采纳
一旦我将@EmbeddedKafka添加到集成测试中，我就会看到以下错误：
Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'embeddedKafka': Invocation of init method failed; nested exception is kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection whi
浏览 15提问于2020-05-05得票数 1
我创造了一个简单的卡夫卡消费者@Configurationpublic ConsumerFactory<String, String> consumerFactory() { props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092");
pr
浏览 9提问于2022-07-15得票数 0
回答已采纳
2回答
我知道我可以找出来自哪个分区记录，但我想知道有什么方法可以动态地获得在特定时刻为消费者分配的分区？也许我需要实现一些侦听器来检测和跟踪分区分配信息？我将spring-kafka 1.3.2与ConcurrentKafkaListenerContainerFactory和@KafkaListener一起使用。
浏览 4提问于2018-02-20得票数 4
目前我正在使用Spring boot 2.4.0和spring-kafka。 我想使用消费者和生产者，而不是kafka admin。我试图通过将"bootstrap.servers“设置为null来覆盖KafkaAdmin类，但不起作用。它仍然“尝试”连接以生成KafkaAdmin并记录错误。
浏览 50提问于2021-01-05得票数 0
回答已采纳
我正在尝试使用Spring Cloud Kafka Streams来处理来自包含不同类型消息的Kafka主题的消息。例如，我们从主题收到一条JSON消息，它可以是类型A或类型B消息。生产者在报头中添加消息类型，有没有办法在Functional Binder中读取报头信息并相应地转换消息？或者还有一个"Choice“选项，用于在消息传入时进行分支，以便将消息路由到正确的转换器？
浏览 15提问于2020-02-08得票数 1
回答已采纳
云服务器
ICP备案
云点播
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号