...
Code Block | ||
---|---|---|
| ||
long startVersion;
long[] versionsToCheck;
byte[] toBytes();
static PartitionConsumerState fromBytes(byte[]); |
PartitionConsumer.java:
Code Block | ||
---|---|---|
| ||
public Iterator<Partition> consumePartitions(); |
...
...
Code Block | ||
---|---|---|
| ||
long startVersion;
long[] versionsToCheck;
byte[] toBytes();
static PartitionConsumerState fromBytes(byte[]); |
PartitionConsumer.java:
Code Block | ||
---|---|---|
| ||
public Iterator<Partition> consumePartitions(); |
...