使用AMQSource的Flink作业不会生成输出

作者: CTO啊哦
发布时间: 2024-03-18 03:50:49 (1月前)
转自：

2 条回复

0#
回复此人
薄情 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> AMQSource期望消息为字节，请参阅AMQSource.class下的run方法中的代码： </p> <pre> <code> Message message = this.consumer.receive(1000L); if (!(**message instanceof BytesMessage**)) { LOG.warn("Active MQ source received non bytes message: {}", message); return; } </code> </pre> <P> 生成数据到ActiveMQ而不是文本消息时： </p> <pre> <code> val message = session.createTextMessage(text) </code> </pre> <P> 使用字节消息： </p> <pre> <code> val message = session.createBytesMessage() message.writeBytes(text.getBytes) </code> </pre> </DIV>

编辑

登录后才能参与评论