蛋疼汇编 2019-05-13 16:55 采纳率: 100%
浏览 653

springcloudbus自定义event消息kafka中收不到消息,springcloud Greenwich版不行,daston版本可以

自定义event,在发送后在Kafka中并没有出现新增的消息
发布事件的代码
protected void fireEvent(String eventAction, Product productDto) {
ProductEvent productEvent = new ProductEvent(productDto,
context.getId(), "service-hello:**",
eventAction, productDto.getItemCode());

    // 发布事件
    context.publishEvent(productEvent);
}

yml配置
server:
port: 2100

spring:
application:
name: SERVICE-HELLO
cloud:
stream:
bindings:
output:
destination: twostepsfromjava-cloud-producttopic
content-type: application/json
kafka:
binder:
brokers: localhost:9092
代码没有报错,但是执行完kafka对应的topic没有消息
同样的代码旧版本可以Daston可以,有没有知道解决办法,或者给个可以的greenwitch版本的demo

  • 写回答

1条回答 默认 最新

  • Conwie 2020-12-08 14:41
    关注

    楼主解决了吗

    评论

报告相同问题?

悬赏问题

  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题
  • ¥15 slam rangenet++配置
  • ¥15 有没有研究水声通信方面的帮我改俩matlab代码
  • ¥15 对于相关问题的求解与代码
  • ¥15 ubuntu子系统密码忘记
  • ¥15 信号傅里叶变换在matlab上遇到的小问题请求帮助
  • ¥15 保护模式-系统加载-段寄存器
  • ¥15 电脑桌面设定一个区域禁止鼠标操作
  • ¥15 求NPF226060磁芯的详细资料