我读过这个(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条消息—它没有间隔,但程序仍在等待超时。
我错过什么了吗?也许我得申报一些边境?例如指定“无间隙”序列的大小?顺便说一下,设置容量不是一个解决方案。
暂无答案!
目前还没有任何答案,快来回答吧!