Thanks for all your comments and taking it easy on me for my first KIP :)
I am trying to check if it's okay for us to start a vote on this? As per
some recent comment I'll change the name to RoundRobinPartitioner.
I'll need to put some effort in writing Scala tests etc. since I'm a novice
with
> I wanted to set *retention bytes* and change *cleanup policy* to *delete*
> to prevent the storage being full. I set following configs in kafka
> streams code:
Are you sure that you use Kafka Streams correctly? Seems like a miss
configuration to switch from compaction to deletion policy. Also
Thanks Guozhang
upgrading kafka stream version to 1.1.0 fixed the issue
On Sat, Sep 1, 2018 at 10:39 PM Guozhang Wang wrote:
> Hello Amir,
>
> The issue you described seems like an old bug that is resolved since 1.1.0
> (as part of the fix in https://jira.apache.org/jira/browse/KAFKA-6150).
