spring-kafka 相关问题

尝试了下面的SPEL表达式，但失败了。需要帮忙！ @KafkaListener(topics = "#{Arrays.asList(${kafka.topic.helloworld}.split(',')).stream().map(p -> p+envSuffix).toArray(String[]::新...

lambda spring-annotations spring-el spring-kafka

回答 3 投票 0

@KafkaListener @SpringBoot-3 中的Payload 验证

我在 @KafkaListener 中使用了记录的有效负载验证方法，它在 SpringBoot-2.7 和 spring-kafka-2.8 中工作得非常好。但是升级到SpringBoot-3.2和spring-kafka-3后....

java spring-kafka

回答 1 投票 0

使用架构注册表生成 Kafka 事件时，运行时期间 io.confluence.kafka.serializers.context.NullContextNameStrategy 值无效

每次在生产环境中生成 Kafka 事件时，我都会在运行时收到以下错误消息。请注意，相同的代码在我的本地设置中可以正常工作，没有任何问题，并且全部

spring-boot apache-kafka spring-kafka classloader confluent-schema-registry

回答 1 投票 0

spring-kafka 和 spring-cloud-starter-stream-kafka 中定义的属性有什么关系？

我继承了一个应用程序，使用 spring-kafka (@KafkaListener) 和 spring-cloud-starter-stream-kafka 的功能。有关 spring-cloud-starter-stream-kafka 属性的文档...

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

回答 1 投票 0

无法读取某个主题所有分区的所有 Kafka 消息

我正在使用一个 Spring Boot Java 项目，其中我提到了一个消费者组，并且刚刚创建了一个消费者实例。这意味着如果我从这个消费者那里轮询数据，它应该默认重新...

apache-kafka spring-kafka kafka-consumer-api apache-kafka-streams apache-kafka-connect

回答 1 投票 0

spring-kafka：RetryTopicConfiguration 具有用于重试和死信主题的自定义名称

我提供了一个用于重试主题配置的bean： @豆公共 RetryTopicConfiguration kafkaRetryTopicConfig(...) { 返回RetryTopicConfigurationBuilder .newInstance() .fixedBackOff(......

spring-boot spring-kafka spring-retry

回答 2 投票 0

使用EmbeddedKafka在Spring Boot测试中测试Spring Kafka Listener

我正在尝试使用 @EmbeddedKafka 在 Spring Boot 测试中测试 Spring Kafka 侦听器。但是，我不断遇到以下异常：没有交易正在进行中；可能的解决方案：运行

spring-kafka spring-kafka-test

回答 1 投票 0

Spring Boot Kafka Listener并发数小于分区数

例如，Kafka 消息的消费情况如何？每个主题 12 个分区 2个微服务正在运行每个微服务都有一个并发 Kafka 消费者，具有以下功能

spring-boot apache-kafka spring-kafka

回答 1 投票 0

如何在spring kafka监听器中无限期重试？

有问题请教。将使用 spring kafka 监听器 @KafkaLister 无限期地重试批处理。我尝试的方法是让侦听器容器具有立即_手动确认，然后不

spring apache-kafka listener spring-kafka

回答 1 投票 0

Kafka 没有可用的确认作为参数

我们正在尝试在java spring项目中实现Kafka Acknowledgment。如果没有确认，我们可以成功接收并读取消息，但是当我们在方法中添加确认时，我们会...

java spring spring-boot apache-kafka spring-kafka

回答 2 投票 0

使用 Spring-Kafka 和 Confluence 模式注册表将带有 JSON 模式的记录发送到 Kafka

我在互联网上找不到任何有关如何使用 spring kafka 将带有 json 模式的记录发送到 kafka 的信息。我怎样才能做到这一点？

java apache-kafka spring-kafka jsonschema confluent-schema-registry

回答 1 投票 0

批处理模式下的 Spring Cloud Stream Kafka 消费者不会重试

我在Spring Boot应用程序中使用Spring Cloud Stream（版本4.0.3）和Kafka Binder来批量消费来自Kafka Topic的消息。当抛出异常时，整个批次都会被处理...

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

回答 1 投票 0

spring-kafka 相关问题

最新问题