回答情况：
提问时间：
问题标签：
*版本之间有没有spring-kafka迁移指南？或者至少一些changelog，这样我就知道我需要查看哪些配置才能进行更改？我在官方文档和项目的github存储库中都找不到任何东西。或者我只需要增加spring-boot和spring-kafka的依赖项，它就可以开箱即用了？
浏览 4提问于2019-03-16得票数 0
回答已采纳
我有几个服务，其中之一是真理之源(SOT)。卡夫卡是他们的信息经纪人。我不时需要生成一组事件，这些事件将被消耗并应用于其他服务中。所谓固定事件迁移。EntityUpdated (topicA)- relation
- id类是在应用事件后在数据库中具有投影的spring实体。 id}
id当前的使用者实现以任意的方式读取主题，并
浏览 6提问于2021-12-17得票数 0
在没有Spring Boot自动配置功能的情况下，是否可以仅将spring-kafka用作配置框架-类似于解析application.properties或application.yaml，并实例化消费者和生产者基本上，只为public static void main应用程序提供了最少的spring和spring-kafka。
谢谢
浏览 12提问于2020-03-04得票数 0
回答已采纳
如何使用spring-kafka库动态创建和删除Topics？谢谢。 我尝试的是AdminClient。但我需要某种包装器，它可以帮助我通过使用spring-kafka来实现这一点，而无需创建自定义类并对其进行测试。 spring-kafka已经有了一个用于创建Topic的a。但是对于删除，我不知道。
浏览 80修改于2021-07-02得票数 0
我试着在stackoverflow上搜索这个，但是没有找到一个合理的答案。我很好奇用@Kafkalistener注释的方法的签名，有什么我们需要遵循的约定吗？如果我们想通过方法注入传入一个spring托管bean，该怎么办？我正在尝试通过方法注入将服务类传递给kafka侦听器- // Do somethi
浏览 0修改于2021-11-24得票数 0
我正在尝试使kafka消费者监听特定的主题，并将消费的消息处理为JSON。我尝试过使用spring docs 中给出的方法，但无法获得JSON格式的消息。@Configurationpublic class ReceiverConfig {
private String bootstrapServers;
public Map consumerConfigs() {
Map props = new HashMap<>
浏览 11提问于2017-02-09得票数 1
回答已采纳
我使用的是spring boot 2.1.5和spring-kafka，版本未指定。
浏览 102提问于2020-04-25得票数 0
回答已采纳
我使用Spring Boot 2.0.7和Spring-Kafka来创建请求/应答模式。我是Spring-Kafka的新手。它允许我创建一个轮询API吗？如果是这样的话，任何示例代码都将非常感谢。
浏览 1提问于2018-12-08得票数 0
我使用的是spring-kafka 2.5.4和spring boot 2.3.2。我有一些带有@StreamListener注解的方法。我想为所有的方法添加一个通用的拦截器。我也不想自己配置ConsumerFactory，而是让spring-kafka来处理。我只想在现有配置的基础上构建，并在其上添加我的RecordInterceptor。
浏览 1修改于2021-02-22得票数 0
回答已采纳
我正试图连接到Kafka broker，后者执行双向SSL/TLS来验证和授权客户端。我已经通过正确的权限创建了证书签名，并存储在我的本地用户目录中。我在用我的application.propertiesspring.kafka.topic=lucija-eliza-topicspring.kafka.ssl.keystore.locat
浏览 5修改于2022-08-30得票数 0
回答已采纳
我正在使用Spring-Kafka框架实现来自Kafka主题的消息消费。
浏览 187提问于2020-04-26得票数 1
回答已采纳
我遇到了一种情况，即应用程序使用消息并生成消息作为对使用的消息的响应。这是使用kafka事务完成的，但是应用程序也有一个定期发送Kafka消息的任务(也使用事务，因为它发送到两个主题)。org.apache.kafka.common.KafkaException: TransactionalId aura-transaction-1: Invalid transition attempted from state IN_TRANSACTION to state IN_TRANSACTION
有人知道原因是什么吗？我正在考虑尝试与不同的kafkaTem
浏览 0修改于2018-12-16得票数 2
回答已采纳
我想知道Spring-Kafka的替代方案。
我在我的应用程序中使用了集成在Spring中的Kafka。我想探索任何可用的替代库。如果库之间共享比较分析，那将是很好的。
浏览 0提问于2019-05-17得票数 1
我在spring-kafka上找到了一个教程，里面他们创建了一个生产者和消费者。然而，该程序是通过测试用例运行的。当测试用例结束时，使用者停止。
浏览 0修改于2017-06-07得票数 4
我的印象是spring-kafka 2.0.0.BUILD-SNAPSHOT需要一个基本spring框架的构建快照才能运行。这是真的吗？将对未发布代码的依赖保持在绝对最低水平，这样spring-kafka就不会因为依赖于springframework本身的未发布版本而无法发布，这不是很有意义吗？我不介意对spring-kafka的依赖，因为这是一个很小的代码库，如果需要的话，我可以将它隔离在我自己的代码库中。
浏览 1提问于2017-06-08得票数 0
但是spring-kafka提供了另一层KafkaMessageListenerContainer，在内部使用kafka-consumer。
浏览 252修改于2020-07-23得票数 0
回答已采纳
这是我的代码，第一个bean查看Topic.TRANSACTION_RAW上的消息，将一个消息一分为二并发送到Topic.TRANSACTION_INTERNAL，第二个bean进行分组和还原，并将其具体化到状态存储"StateStore.BALANCE“中。最后一个是让ReadOnlyKeyValueStore从"ReadOnlyKeyValueStore“中读取状态。 @Configuration(proxyBeanMethods = false)public class MyKafkaStreamsConfiguration {
浏览 20提问于2021-04-27得票数 0
如果我不使用spring-kafka，只使用纯kafka-api就可以了。当我在命令行中绑定消费者时，它也可以工作--我看到由java-code-producer发送的消息。
浏览 2修改于2018-04-03得票数 2
回答已采纳
DeadLetterPublishingRecoverer是否需要单独的KafkaTemplate？
浏览 0提问于2019-11-30得票数 0
我已经配置了3个kafka集群，我正在尝试使用spring-kafka。但是当我杀死kafka时，我不能发送其他消息到队列中。Kafka版本2.0.0 spring-kafka版本2.0.1 kafka-topics.sh --describe -zookeeper=zoo1:2181打印 KAFKA_SWARM_TESTConfigs:
Topic: KAFKA_SWARM_TEST Partition: 0 Leader: 2 Replicas: 1,2 Isr: 2,1 spring-kafka但
浏览 21修改于2019-08-26得票数 3
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号