search

apache / rocketmq-flink

RocketMQ integration for Apache Flink. This module includes the RocketMQ source and sink that allows a flink job to either write messages into a topic or read from topics in a flink job.
https://rocketmq.apache.org/
Apache License 2.0
139 stars 88 forks source link

消息有序性问题 #30

Closed vendanner closed 1 year ago

vendanner commented 2 years ago
  1. SQL 模式没有参数可以设置 MessageQueueSelector
  2. 设置了MessageQueueSelector，producer 发送不会重试，要自己做重试机制？
  3. SQL模式默认是同步发送，效率问题？
ShannonDing commented 1 year ago

it is better to disscuss in the emaillist or in sig.