Fork me on GitHub

any particular reason the kafka plugin writes :done to the topic when finished? crashing hard when you have a compacted topic (key is required)


@ckarlsen: the done is written when the job is completed (i.e. The done is put on all the input tasks). We'll be getting rid of the concept in the next version, and we don't write it on multiple partitioned topics


It sounds like we should remove it from single partitioned topics too