假设我们在独立模式下使用Kafka S3接收器连接器。
正如写在融合页面上一样，它只有一次交付保证。
我不知道它是如何工作的...
例如，在某个时间点，连接器向S3写入了消息，但是没有设法将偏移值提交给Kafka主题并被压碎了。
下次启动时，应该再次处理以前的消息吗？
还是内部使用交易？
Kafka转S3连接器
•
问答
tiancai61 回答：Kafka转S3连接器
暂时没有好的解决方案，如果你有好的解决方案，请发邮件至：iooj@foxmail.com