Re: Consumer Parallelism

[Mingtao Zhang]

Is it anyhow related to the issue?

WARN No previously checkpointed highwatermark value found for topic RAW
partition 0. Returning 0 as the highwatermark
(kafka.server.HighwaterMarkCheckpoint)

Mingtao