spring-kafka 相关问题

Spring for Apache Kafka（spring-kafka）项目将核心Spring概念应用于基于Kafka的消息传递解决方案的开发。

我正在使用 Kafka 来处理一个有 4 个分区的主题。 Kafka 中消息的保留期 (TTL) 默认设置为 7 天。我正在运行一个非流式批处理作业，处理来自...的数据

apache-kafka spring-kafka apache-kafka-streams confluent-kafka-python

回答 1 投票 0

从 kafka 3.0 开始，我们默认获得最强的交付保证（acks=all，enable.idempotence=true）。（https://www.confluence.io/blog/apache-kafka-3-0-major-improvements-and-new-features/）。大多数情况下，

apache-kafka spring-kafka kafka-transactions-api

回答 1 投票 0

来自不同主题的一个消费者具有相同的密钥

我有一个用例，其中有 2 个不同的主题，来自 2 个不同的应用程序/生产者，其中的事件通过键（例如用户 ID）相关。为了顺序处理......

apache-kafka spring-kafka

回答 1 投票 0

批处理监听器没有 BackOff 的 DefaultAfterRollbackProcessor

我正在尝试为批处理侦听器配置错误处理，这样，如果单个记录处理失败，则整个批次将被发送到死信主题（带有一些额外的日志记录）...

spring apache-kafka spring-kafka

回答 1 投票 0

如何使用Spring Kafka的Acknowledgement.acknowledge()方法进行手动提交

我第一次使用Spring Kafka，我无法在我的消费者代码中使用Acknowledgement.acknowledge()方法进行手动提交，如此处https://docs.spring.io/spring-kafka/referenc所述。 .

java spring-boot kafka-consumer-api spring-kafka

回答 4 投票 0

Spring-Kafka 生产者消息太慢

我正在编写一个spring-boot应用程序，接收请求并进行一些数据处理，然后将数据写入kafka。当我进行压力测试时，我发现kafka消息传递非常慢。数据公关...

java apache-kafka spring-kafka

回答 1 投票 0

Kafka AdminClient 连接问题：Spring 应用程序中“与 localhost/127.0.0.1 的连接已断开”

我在从本地运行的 Spring 应用程序连接到我的 Kafka 集群时遇到问题。应用程序成功将 localhost 解析为 127.0.0.1，但随后立即断开连接...

docker networking spring-kafka

回答 1 投票 0

ErrorHandlingDeserializer 中的 Kafka 消息验证

我不明白应该如何配置它来验证 ErrorHandlingDeserializer 中的消息。春天：格式：使用：类型：标题：假卡夫卡：消费者：关键-deseria...

validation spring-kafka

回答 1 投票 0

KafkaListenerEndpointContainer 无法使用 Spring Kafka 创建 Kafka 事务

我正在使用 spring-Kafka 2.2.2.RELEASE(org.apache.kafka:kafka-clients:jar:2.0.1) 和 spring-boot(2.1.1)。我无法执行事务，因为我的侦听器无法获取分区...

java spring-boot apache-kafka kafka-consumer-api spring-kafka

回答 1 投票 0

如何禁用@KafkaListener运行时注释的方法

我有一个 spring-boot 应用程序，它使用 spring-kafka 和 @KafkaListener 注释。我正在寻找一种与消费者交互的方法，这样我就可以禁用消费者运行时而无需...

java apache-kafka spring-kafka

回答 1 投票 0

Spring boot Kafka无法使用ContainerCustomizer设置authExceptionRetryInterval

我想将 authExceptionRetryInterval 设置为某个值，以便我的 kafka 侦听器不会因随机身份验证失败而被破坏。我有一个简单的监听器类： @成分类监听器{ @

java spring-boot spring-kafka

回答 2 投票 0

Spring Boot 中跨微服务的 DTO 的 Kafka 反序列化问题。类不在受信任的包中

我目前正在开发一个具有微服务架构的Spring Boot应用程序。我有一个生成消息的身份验证服务和一个使用消息的用户服务。我在反序列化时遇到麻烦...

java apache-kafka jackson spring-kafka

回答 1 投票 0

通过外部触发器寻求偏移

目前我使用 AcknoledgingMessageListener 来使用 spring-Kafka 实现 Kafka 消费者。此实现帮助我监听特定主题并通过手动确认处理消息。我现在

spring-kafka

回答 2 投票 0

我希望每当我调用此函数时再次消耗特定偏移量和分区的旧kafka事件。我应该使用 Kafka Stream 还是 kafkaListner

当旧事件数量较少或较多时，这是首选。我正在使用弹簧靴

spring-boot apache-kafka spring-kafka apache-kafka-streams

回答 1 投票 0

如何在springboot应用程序中使用micrometer从Kafka消费后传递相同的traceId

我在我的 springboot 应用程序中使用微米追踪。我的应用程序有一个 Api，它将数据发送到 kafka 主题，然后使用它。我希望我的应用程序具有相同的traceId...

spring-kafka micrometer spring-micrometer micrometer-tracing

回答 1 投票 0

Kafka Streams 管理客户端断开连接

我们正在使用 Kafka Streams 进行一些流处理，我们在可观测系统中看到一些奇怪的日志。一切正常，处理工作没有任何问题，但是...

java spring-boot spring-kafka apache-kafka-streams

回答 1 投票 0

如何制作通用的kafka消费者工厂？

现在我正在尝试让我的两个微服务相互通信。第一个是发送这样的消息： @PostMapping("/testPost") 公共 ResponseEntity 测试...

java spring spring-boot apache-kafka spring-kafka

回答 1 投票 0

如何设置 KafkaItemReaderBuilder 来读取所有分区？

我目前使用分区方法以及要使用的分区列表：分区(0, 1, 2) 如果添加了分区3，则不会消耗它。我如何告诉 KafkaItemReaderBuilder 我想要...

java spring apache-kafka spring-batch spring-kafka

回答 1 投票 0

Spring boot 3.2.9 云流-Kafka Binder。 classcastException - 类 java.lang.Byte 无法转换为类 java.util.UUID

我创建了一个基于spring示例的应用程序 - 批量生产者-消费者对示例进行了一些更改 - 生产者和消费者/处理器是不同的应用程序。处理器是

spring-boot spring-kafka spring-cloud-stream spring-cloud-stream-binder-kafka

回答 1 投票 0

使用多个kafka listner注释

我是卡夫卡的新手，正在尝试探索可能性。但只想知道以下场景的利弊。如果我们在一个消费者组中有两个主题并且如果我们尝试使用两个

spring apache-kafka spring-kafka kafka-consumer-api

回答 1 投票 0

spring-kafka 相关问题

最新问题