这个kcat repo有一个示例,说明如何读取(=2000)
Kafka 主题中的最后 N 条记录(syslog
在本例中):
$ kcat -C -b mybroker -t syslog -p 0 -o -2000 -e
该参数-o
从主题的结尾偏移,并-e
指示直到主题的结尾。如果我想从一个特定位置流式传输Nth
到另一个位置(N + k)th
,而不知道主题的完整长度,那么语法是什么?
我正在尝试对正在生成的数据进行某种随机完整性检查,其中数据太大而无法全部消耗。我希望通过随机使用一系列数据并验证它来做到这一点。因此,这个问题。