apache Camel 流重新排序工作不正常

6qftjkof  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(239)

我读过这个(https://camel.apache.org/components/latest/eips/resequence-eip.html#_stream_resequencing)描述并尝试实现流重排序。问题在于:

from("kafka:in?brokers=localhost:9092&groupId=test")
                .resequence(header("seqNum"))
                .stream()
                .timeout(10000L)
                .to("kafka:out?brokers=localhost:9092");

我的程序总是等待超时,并且在超时之前不发送消息—即使序列没有任何间隔。例如,我分别用“seqnum”1、3、4、2发送了4条消息—它没有间隔,但程序仍在等待超时。
我错过什么了吗?也许我得申报一些边境?例如指定“无间隙”序列的大小?顺便说一下,设置容量不是一个解决方案。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题