spring-kafka 相关问题

在我的主 application.properties 中，我有： spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer 这一切都工作正常，并且值被反序列化......

apache-kafka spring-kafka

回答 1 投票 0

Kafka 反序列化错误：标头中没有类型信息且未提供默认类型

我正在尝试将自定义负载（对象）从生产者发送到消费者。有效负载是一个具有三个或四个字段的简单类。我在反序列化时遇到 Kafka 问题

java json apache-kafka spring-kafka

回答 1 投票 0

当您有多个服务实例监听某个主题时会发生什么？

我的理解是Spring-kafka管理服务内的并发。即侦听器只会使用来自指定分区的消息。多个ins的时候也是这样吗...

apache-kafka spring-kafka

回答 1 投票 0

有没有更好的方法使用kafka实现多租户？

我正在尝试使用 Spring Boot 实现多租户微服务。我已经实现了网络层和持久层。在 Web 层上，我实现了一个设置租户 ID 的过滤器...

java spring multi-tenant spring-kafka

回答 2 投票 0

如何配置2个Spring Kafka监听器监听同一个主题以拥有自己的重试和死信主题

在 Spring Kafka 中，我有两个 Kafka 监听器监听同一个主题。我希望两个监听器都有自己的重试和死信主题，这样如果一个监听器发生故障，它就不会得到

apache-kafka spring-kafka

回答 2 投票 0

如何在具有flowable的Spring Boot项目中配置kafka主题

启用 flowable 和 kafka，应用程序会运行，但是当我配置 kafka bean ConcurrentKafkaListenerContainerFactory 时。它会产生一个错误： <<'org.springframework.kafka.core.

spring spring-boot spring-kafka flowable

回答 1 投票 0

如何替换已弃用的@StreamListener？

我正在使用 Spring Boot 和 Kafka。迁移到 Spring Boot 和其他版本的最新版本时，我遇到了以下问题：@StreamListener 已弃用并从库中删除。我有一个主题...

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

回答 2 投票 0

创建 EmbeddedKafka 代理时，使用 @EmbeddedKafka 进行测试失败并出现 TimeoutException

从 Spring-Boot 2.4 -> 2.7 升级并升级 Kafka 2.8.2 -> 3.6.1 后使用我的应用程序运行单元测试我有这样的单元测试设置： @RunWith(SpringRunner.class) @SpringBootT...

java spring spring-boot apache-kafka spring-kafka

回答 1 投票 0

动态地将同一事件路由到多个kafka主题

我有一个要求，我必须根据某些条件评估将kafka流路由到多个主题。我遇到了TopicNameExtractor接口，但它只支持单个主题。是吗...

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

回答 1 投票 0

contractVerifierMessaging.receive 为空

我正在按照 spring-cloud-contract-samples/ Producer_kafka_middleware/ 中描述的方式使用测试容器为 Kafka 消息传递设置合同测试。与嵌入式 Kafka 配合良好，但不适用于

automated-tests spring-kafka testcontainers spring-cloud-contract

回答 2 投票 0

使用 Spring Retry 向固定主题发送 kafka 可重试消息

我正在使用spring retry（spring-kafka.version 2.9.13）为kafka消费者实现重试机制。我的目标是使用不是由 spring-kafka 自动创建的自定义重试主题（或多个主题）。乙...

spring-boot apache-kafka spring-kafka

回答 1 投票 0

使用bitnami Helm Chart安装kafka

当我尝试按照 Helm Chart 安装说明连接生产者时遇到身份验证问题：我正在安装这个 kafka helm 图表： https://artifacthub.io/packages/helm/

apache-kafka spring-kafka

回答 1 投票 0

spring-kafka 相关问题

最新问题