Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。
Spring boot @KafkaListener 不使用框架中提到的 SPEL 监听主题名称
我开发了一个kafka监听器。以下是我设计的不同课程： 类 KafkaProperties { 公共字符串主题ZZZ； 公共字符串组ID； ... } 类 KafkaConfig { ...
java.lang.RuntimeException：不可为 null 的字段 authBytes 从 Spring Boot 序列化为 null 到 Azure 事件中心
我正在使用 v2.7.5 开发一个简单的 Spring Boot 应用程序，并尝试将消息发送到事件中心。有人可以指导我吗？ 错误： java.lang.RuntimeException：不可为 null 的字段 authBytes 为
@SpringBootApplication 公共类 SpringKafkaApplication { 公共静态无效主（字符串[] args）{ SpringApplication.run(SpringKafkaApplication.class, args); } @Autowired
当密码包含“:”字符时，JaasConfig 会错误地解析应用配置
我有 SASL 身份验证问题，该身份验证使用 JaasConfig 配置来构建登录连接字符串 我的连接字符串看起来像 required username= pass...
在 Docker-compose 中使用 Kafka 运行 Spring Boot 应用程序
我有应用程序（kafka客户端）。我有下一个属性： spring.kafka.bootstrap-servers=127.0.0.1:29092 spring.kafka.consumer.group-id=mc3 我在 Docker-compose 中有 kafka： 卡夫卡： 图片：
我们正在考虑在我们的消息传递中使用 Kafka，我们的应用程序是使用 Spring 开发的。所以，我们打算使用spring-kafka。 生产者将消息作为 HashMap 对象放入...
KafkaTemplate 和 KafkaProducer 发送方法的区别？
我的问题是在使用kafka的Spring Boot微服务中什么适合使用KafkaTemplate.send()或KafkaProducer.send() 我使用 KafkaConsumer 而不是 KafkaListener 来轮询记录
如何在 Kubernetes multipod 部署中使用 spring kafka 处理 Kafka 容器生命周期
我正在使用 Spring kafka 实现，我需要通过 REST API 启动和停止我的 kafka 消费者。为此，我正在使用 KafkaListenerEndpointRegistry endpointRegistry 端点注册表。
某些消息随机获取 IAMClientCallbackHandler 类未找到异常
在我们目前的用例中，我们一条一条地发送消息[不是批量]以维持传入的顺序顺序，同时一条一条地发送大约 5000 多条消息或使用
Spring Kafka - offsetsForTimes 方法对某些分区返回 null
我使用 spring-boot 2.2.11、spring-kafka 2.4.11 和 apache kafka-clients 2.4.1 我让我的消费者实现了 ConsumerAwareRebalanceListener，并且我试图在特定时间戳之后寻求偏移
使用 Spring Kafka 的 Kafka Producer 在尝试生产时需要很长时间才能刷新元数据
我们对 Kafka 有一个标准设置，我们使用 @KafkaLisetener 来侦听某个主题上的事件，并使用 KafkaTemplate 将响应发送到另一个主题。 为了提高吞吐量，我们增加...
我怎样才能转到“@Override public void onFailure(Throwable ex) { ... }”？ 它总是“@Override public void onSuccess(SendResult result) {...}。 我...
即使在确认消息后，重复消息也会多次发送到@Dlthandler
我正在尝试测试 Kafka 的 @RetryableTopic 功能，在重试消息 3 次后，我想将其推送到 Kafka SQS。我收到来自重试线程的呼叫 4 次并呼叫 DltHand...
Spring Boot - Kafka - JSON 对象反序列化
这里已经有一个类似的问题，但是它并没有完全解决我的问题。 在我的消费者中，我有一个产品类别。要阅读主题产品，我使用以下命令： 公共类 KafkaMessagingSer...
Spring Boot - Kafka Consumer Bean 范围
我在具有 SCOPE_REQUEST 范围的 Spring Boot 应用程序中使用 CacheManager。 @豆 @Scope（值= WebApplicationContext.SCOPE_REQUEST，proxyMode = ScopedProxyMode.TARGET_CLASS） 公共缓存管理器
Spring Boot 3 KafkaTemplate 跟踪（traceId、spanId、baggage）丢失
在 Spring Boot 3 之前，跟踪（包括 Kafka 跟踪）是使用 Sleuth 执行的。 可以通过 Kafka 传播跟踪上下文（traceId、spanId、baggage）。 侦探不再存在。 ...
使用架构注册表对 avro 消息进行 Spring 云合约测试
我正在查看 spring 文档和 spring github，我可以看到一些非常基本的异步 kafka 消息传递（生产者和消费者）示例，它们通过 json 消息和 Kafka 主题进行通信，但是...
SetErrorHandler 在 Kafka 3.1.1 版本中不受支持，在 3.0.14 中已弃用，替代品是什么
在 Spring boot 3.1.2 中，此方法已弃用。这是kafkaConfig类 公共并发KafkaListenerContainerFactory\ kafkaListenerContainerFactory() {
Kafka 消费者 fetch-min-size (fetch.min.bytes) 是否等待提到的大小被填满？
假设有107条记录，每条记录1kb。如果获取大小为 15kb，则在 7 次迭代中将消耗 105kb。现在只剩下 2kb，我会在下一次迭代中获得剩余的 2 条记录吗...
Java SpringBoot apache-kafka 可以反序列化对象
Kafka 生产者和消费者配置问题 我在 Spring Boot 应用程序中遇到通过 Kafka 发送和接收对象的问题。我已经配置了 Kafka 生产者和消费者，但是