基于事件流实现Kafka消息路由 步骤二:测试验证登录分布式消息服务Kafka管理控制台。在左侧导航栏,单击实例列表,选择事件流的源实例。在主题管理页面,选择源的目标主题,操作列点击更多,然后点击生产消息。在生产消息对话框输入想要发送的消息,然后点击发送消息。发送消息后返回实例列表,选择事件流的目标实例,进入管理。在消息查询页面,选择目标实例的目标主题,然后按时间查询,查询最近收到的消息。查看查询到的Key和Value值是否与生产的消息一致,详见图2。图2 在分布式消息服务Kafka管理控制台查看消息详情