蛋疼汇编 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
    关注

    楼主解决了吗

    评论

报告相同问题?

悬赏问题

  • ¥15 stata安慰剂检验作图但是真实值不出现在图上
  • ¥15 c程序不知道为什么得不到结果
  • ¥40 复杂的限制性的商函数处理
  • ¥15 程序不包含适用于入口点的静态Main方法
  • ¥15 素材场景中光线烘焙后灯光失效
  • ¥15 请教一下各位,为什么我这个没有实现模拟点击
  • ¥15 执行 virtuoso 命令后,界面没有,cadence 启动不起来
  • ¥50 comfyui下连接animatediff节点生成视频质量非常差的原因
  • ¥20 有关区间dp的问题求解
  • ¥15 多电路系统共用电源的串扰问题