Spring Boot 3.2.2 连接 RocketMQ 5.1.2 报错如何解决?
Started container failed. DefaultRocketMQListenerContainer{consumerGroup='topic_02_CONSUMER', namespace='', namespaceV2='', nameServer='192.168.50.20:9876', topic='topic_02', consumeMode=CONCURRENTLY, selectorType=TAG, selectorExpression='*', messageModel=CLUSTERING', tlsEnable=false, instanceNam...
1 回答974 阅读✓ 已解决
Kafka是不会直接接收Http请求的。一般是程序里接收数据然后写到kafka里,另一个程序再去kafka里读取,也就是Producer和Consumer。
至于怎么写到kafka里,用kafka提供的client就可以了。