我在spring boot应用程序的消费者接收器上使用@SendTo注释,没有参数。收到的消息包含头部"Kafka_replyTopic",但@SendTo无法读取,kafka在发送回复时抛出异常: Listener failed; nested exception is java.lang.IllegalStateException: With no topic header, a defaultTopic is required
我有事务性和正常的生产者在应用程序,是写到主题卡夫卡-主题如下。
事务性Kafka生产者的配置
@Bean
public Map<String, Object> producerConfigs() {
Map<String, Object> props = new HashMap<>();
// list of host:port pairs used for establishing the initial connections to the Kakfa cluster
props.put(Pro
(在开始提问之前,我的英语可能不足以清楚地描述所有的事情。如果你不明白,请告诉我。)
我试图发送一个数据对象从一个弹簧项目(生产者)到B弹簧项目(消费者)卡夫卡。
问题是A和B中的数据对象有不同的类路径。因此,B项目数据类无法映射A项目的字段。
但是两个对象有相同的字段。所以我想从A项目中获取对象作为B项目的一个参数。
错误消息
Listener failed; nested exception is
org.springframework.kafka.support.serializer.DeserializationException: failed to deserialize; n
我对卡夫卡很陌生。我有以下架构:
1) 2 servers runing application logics and database, can I write kafka producer on these servers wrapped with docker container ?
2) 1 server reserved for kafka broker and zookeeper
3) 1 sever reserved for kafka comsumer
我很困惑
1) whether I can run kafka producer, broker and consumer
我试图在我的春季引导应用程序中使用kafka侦听器,但是服务器启动失败了,出现了以下错误:根本原因是它正在org.springframework.kafka.listener.config子包中寻找org.springframework.kafka.listener中可用的org.springframework.kafka.listener。
***************************
APPLICATION FAILED TO START
***************************
Description:
An attempt was made to call