我有一个kafka监听器，它正确地接收数据，但EventData ss = consumerRecord.value()提供ClassCastException。consumerRecord.value()); }Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to com.betstars.betsyncadapter.
浏览 82提问于2018-02-06得票数 0
我有阅读卡夫卡主题的阿夫罗讯息的春季程序。当消息读取发生异常时：在调试中，我看到ClassUtils.isAssignable为同一个类返回false：
Class <?> targetClass = parameter.getParameterType
浏览 8提问于2017-10-20得票数 6
:65) ~[spring-kafka-2.4.5.RELEASE.jar:2.4.5.RELEASE] at org.springframework.kafka.liste
浏览 44提问于2020-07-21得票数 2
props.setBatchErrorHandler(new SeekToCurrentBatchErrorHandler());}Kafkaversion : 1.0.2, spring-kafka:2.1.10.RELEASE & springBootVersion = '2.0.5.RELEASE'
上下文初始化过程中遇到的异常-取消刷新尝试: org.springframework.context.ApplicationContextExcept
浏览 1提问于2018-10-26得票数 1
回答已采纳
2回答
我正在阅读这里的文档，，我不知道用批处理侦听器实现有状态重试的正确方法是什么这对于我的用例来说不是问题，因为我只想重试整个批。问题出现在下一节，讨论如何使用有状态重试标志在重试之间进行使用者轮询，以防止代理放弃我的使用者。
浏览 2提问于2019-08-27得票数 1
回答已采纳
to send Message to channel 'test.group-1.errors'; nested exception is java.lang.ClassCastException:=group-1}] at org.springframework.
浏览 158提问于2020-04-03得票数 2
>)' threw exception; nested exception is java.lang.ClassCastException: java.util.LinkedHashMap cannotbe cast to com.consumerApp.models.Record; nested exception is java.lang.ClassCastException: java.util.LinkedHashMap(KafkaMessageListenerContainer.java:934) [spring-kafka
浏览 30提问于2019-08-28得票数 3
回答已采纳
MethodArgumentResolutionException.class, ClassCastException.class(ProducerFactory.java:120)
at org.springframework.kafka.listener.DeadLetterPublishingRecoverer.determineSendTimeout(DeadLetterPublishingRecoverer.java:628)
浏览 14提问于2022-09-29得票数 0
回答已采纳
我对Kafka非常陌生。我正在试图弄清楚和理解错误场景将如何为@Listener batch consumer factory工作。
我在做的是..。服务器是否正在运行并且能够连接到特定的主题-为什么我要问这个问题是在本地停止zookeeper和Kafka服务器之后尝试了zookeeper和Kafka服务器，但是没有出现错误或异常。Kafka Producer，我的意思是Template发送消息，在停止Kafka Server后抛出错误，但在Listener没有发现错误
浏览 4提问于2017-02-02得票数 4
2回答
org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.licious.kafa2sfwrapper.kafkacosumers.CustomersCDCConsumer.listenGroupFoo/:2.6.6]
at org.springframework.kafka.listener.KafkaMessageListener
浏览 296提问于2021-02-26得票数 3
回答已采纳
谢谢 org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception=mypublish-reader-group, target-protocol=kafka}]
浏览 132提问于2021-06-27得票数 1
回答已采纳
Message to channel 'my.message.destination.my.message.group.errors'; nested exception is java.lang.ClassCastExceptionat org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListenerat org.springframework.kafka.<em
浏览 30提问于2019-03-23得票数 0
回答已采纳
我正尝试在一个非常简单的项目中使用Spring Kafak，但是当我收到一个字符串消息时，我得到了一个错误。: Listener failed; nested exception is org.springframework.kafka.KafkaException: No method found for(KafkaMessageListenerContainer.java:1790) [spring-kafka-2.3.7.RELEASE.jar:2.3.7.RELEASE]
at org.springfram
浏览 142提问于2020-04-11得票数 0
回答已采纳
1回答
但是当我运行它时，当使用kafka模板发送请求时，它会给org.apache.kafka.common.errors.SerializationException: Can't convert keyof class java.lang.Integer to class org.apache.kafka.common.serialization.StringSerializer specifiedpartitions = 1)class KafkaApplicationTests {
@
浏览 4提问于2020-05-24得票数 0
2回答
带Avro反序列化器的弹簧卡夫卡
、、、、
"test", "EventDataRequest": {"user": "54321", "panId": "1234", "empId": "5"}})
org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void className(
浏览 0提问于2020-06-16得票数 1
回答已采纳
2回答
不存储大量数据
、、
我正试着让卡夫卡和船坞写作一起。: 1 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT://localhost:9092 KAFKA_GROUP_INITIAL_REBALANCE_DEL
浏览 1提问于2020-04-02得票数 8
回答已采纳
specified in Caused by: java.lang.ClassCastException: class java.lang.String cannot(Serializer.java:62) ~[kafka-clients-2.3.1.jar:na]at org.springframework.kafka.core.KafkaTemplate.
浏览 21提问于2020-05-11得票数 0
(HandlerAdapter.java:48)at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessa
浏览 1提问于2019-06-19得票数 0
1回答
private ExampleDialogListener listener; private String positive;
private ExampleDialogListener listener), positivetext, Toast.
浏览 26提问于2019-12-16得票数 1
回答已采纳
我让Kafka在openshift上运行，并公开了访问Kafka代理的路由(TLS passthrough)。下面是代理的server.properties。我在Kafka broker上有密钥库和证书，在客户端上有ca-cert。EXTERNAL://0.0.0.0:9043inter.broker.listener.name=INTERNAL
<em
浏览 0提问于2020-08-02得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号