Created a Jira for each:
- https://issues.apache.org/jira/browse/KAFKA-6998
- https://issues.apache.org/jira/browse/KAFKA-6999
-Matthias
On 5/11/18 10:06 AM, Guozhang Wang wrote:
> Hello Steven, thanks for pointing it out. I think both of the mentioned
> issues worth be improving:
>
> 1. The
Sorry for late reply.
> The source stream contains millions of messages produced over several
months.
What is the retention time of the output topic? If it is smaller than
the message timestamp (that I expect to be multiple month old), on write
the data would be delete quitckly, because it's olde
