0

这个kcat repo有一个示例,说明如何读取(=2000)Kafka 主题中的最后 N 条记录(syslog在本例中):

$ kcat -C -b mybroker -t syslog -p 0 -o -2000 -e

该参数-o从主题的结尾偏移,并-e指示直到主题的结尾。如果我想从一个特定位置流式传输Nth到另一个位置(N + k)th,而不知道主题的完整长度,那么语法是什么?

我正在尝试对正在生成的数据进行某种随机完整性检查,其中数据太大而无法全部消耗。我希望通过随机使用一系列数据并验证它来做到这一点。因此,这个问题。

4

0 回答 0