spring-kafka 相关问题

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

应该是什么卡夫卡消费者并发（对于缩放）一个适当的值？

我创建一个新的服务，这将是卡夫卡的话题的消费者。这是春天应用程序，所以我使用的是弹簧卡夫卡。主题有20个分区。在开始的时候，也有Kubernetes两个实例。在...

apache-kafka spring-kafka
回答 1 投票 0

春季云流卡夫卡 - 方法必须声明

我已经配置了带弹簧的云流弹簧启动的基于应用程序。我想在KStream工作，但我不断收到错误“java.lang.IllegalArgumentException异常：方法必须声明”。 ...

spring spring-boot spring-cloud-stream spring-kafka
回答 2 投票 2

使用DeadLetterPublishingRecoverer和手动ack模式的Spring Kafka侦听器

我很难理解如何解决此问题，因此我在这里提出要求，希望其他人已经面临相同的问题。我们正在使用手动ack模式和...

java spring spring-kafka
回答 2 投票 4

如何创建嵌入春季云流中的卡夫卡单元测试

对不起，这个问题太普通，但有人对如何与卡夫卡嵌入式执行生产者和消费者测试的一些教程或指南。我已经试了，但也有几个版本？

junit apache-kafka spring-cloud-stream spring-kafka
回答 1 投票 4

春季启动卡夫卡：无法启动消费者由于NoSuchBeanDefinitionException

随着我的春节，启动服务试图启动一个卡夫卡消费者看到NoSuchBeanDefinitionException而无法启动服务本身。下面是一个包含所有必需的我bean类...

spring apache-kafka kafka-consumer-api spring-kafka
回答 2 投票 7

春天卡夫卡模式是不是在受信任的包

我正在微服务与弹簧卡夫卡2.1.5和弹簧引导2.0.5第一个服务会产生一些消息，卡夫卡和第二个会消耗他们，同时消耗我具有...

java spring spring-boot apache-kafka spring-kafka
回答 1 投票 0

如何存放卡夫卡主题只有最新的键值

我有一个具有数据来它流的话题。我需要的是从这个话题，只有最新的一组给定键的值的创建一个单独的话题。我想到了一个KTable的整...

scala apache-kafka apache-kafka-streams spring-kafka
回答 1 投票 0

Spring Kafka @KafkaListener - 重试发送失败的消息并手动提交偏移量

我使用@KafkaListener来消费kafka主题，我有一个应用程序逻辑来处理不同消费者组中的多个消费者的每条记录。现在我的问题陈述是......

spring-boot apache-kafka kafka-consumer-api spring-kafka
回答 1 投票 1

在容器错误处理程序的情况下获取主题名称，分区和偏移量

我从Kafka主题消费数据时得到反序列化异常。我想将偏移量设置为当前+1。我在容器级别有一个错误处理程序，它接受异常，消费者记录......

apache-kafka kafka-consumer-api spring-kafka
回答 1 投票 0

使用Spring Kafka续订Kerberos票证

我们最近在我们的kafka集群中实现了kerberos。客户需要使用SASL_SSL与这个集群交谈。由于我们在项目中使用spring-kafka，我遇到了这个......

apache-kafka spring-kafka
回答 1 投票 0

即使Kafka监听器（spring-kafka）没有初始化，如何启动spring应用程序

我正在使用一个使用spring-kafka的Kafka监听器的应用程序。我面临的问题是，当Kafka监听器没有打开时，弹簧上下文初始化失败（各种...

spring apache-kafka spring-kafka
回答 1 投票 3

Spring Kafka-防止消费者在Spring Boot中构建期间连接Kafka主题

我在容器工厂上做了autoStartup（false），但不确定我应该在哪里注入KafkaListenerEndpointRegistry。我不希望消费者在构建时连接。它应该连接Kafka ......

java spring-boot spring-kafka
回答 1 投票 1

kafka embedded：java.io.FileNotFoundException：/tmp/kafka-7785736914220873149/replication-offset-checkpoint.tmp

我在集成测试中使用kafkaEmbedded，我在java.io.FileOutputStream中得到FileNotFoundException：java.io.FileNotFoundException：/tmp/kafka-7785736914220873149/replication-offset-checkpoint.tmp ....

spring-boot cassandra spring-kafka
回答 2 投票 6

spring-kafka 2.0.x kafka .11和spring-boot 2.0.0.RELEASE兼容性问题：java.lang.NoSuchMethodError

从spring-boot 2.0.0.Mx升级到2.0.0.RELEASE时，看起来spring-boot，spring-kafka 2.0.x和kafka .11之间存在不兼容性。兼容性问题显然是......

spring-boot apache-kafka spring-kafka
回答 1 投票 1

Kafka主题，Spring-cloud-stream频道和Spring-cloud-stream目的地之间的差异

劳驾!我从队友那里得到了同样的问题。他们问我Kafka话题，Spring云流频道和Spring Cloud流目的地有什么不同点。我们试着......

apache-kafka spring-cloud-stream spring-kafka
回答 1 投票 -1

Spring Kafka JsonDesirialization MessageConversionException无法解析类名Class not found

我有两个应该通过Kafka进行通信的服务。让我们将第一个服务称为WriteService，将第二个服务称为QueryService。在WriteService端，我对...

spring spring-boot apache-kafka json-deserialization spring-kafka
回答 2 投票 3

如何确认spring kafka中的当前偏移量以进行手动提交

我第一次使用Spring Kafka而且我无法在我的消费者代码中使用Acknowledgement.acknowledge（）方法进行手动提交。如果我的消费者遗失了什么，请告诉我...

apache-kafka spring-kafka
回答 3 投票 7

在Spring Boot关闭之前Kafka手动确认

所以问题很简单，但我现在找不到答案了。我有我的Kafka消费者手动确认，在应用程序关闭之前我想执行一些...

java spring-boot apache-kafka spring-kafka predestroy
回答 1 投票 0

反序列化后如何处理SerializationException

我在Spring Kafka设置中使用Avro和Schema注册表。我想以某种方式处理SerializationException，它可能在反序列化期间抛出。我找到了以下两个......

serialization error-handling deserialization spring-kafka
回答 1 投票 6

如何阅读Kafka主题中的所有记录

我在客户端使用kafka：kafka_2.12-2.1.0，spring kafka并且遇到了问题。我需要通过读取kafka主题中的所有现有消息来加载内存中的映射。我做了......

apache-kafka kafka-consumer-api spring-kafka
回答 2 投票 0
最新问题
© www.soinside.com 2019 - 2024. All rights reserved.