Issue opened: https://issues.apache.org/jira/browse/KAFKA-7281
The config command accepts the new format as described, but the error
message still references the old format/restrictions.
br, Patrik
On 12 August 2018 at 23:47, Matthias J. Sax wrote:
> I think, at command line tool level, you need
I think, at command line tool level, you need to use
--add-config log.cleanup.policy=[compact,delete]
ie, you need to add square bracket to mark the config as a list.
This is different to Java code for which you would use
props.put("log.cleanup.policy", "compact,delete");
The config should be
We've run into some unexpected behavior around this as well, though I
forgot to send in a note when we found it so I'm fuzzy on the details at
the moment. I'll chime back in if I can dig up exactly what we were doing,
but I'd also welcome a ruling from someone with knowledge of the code. I
seem to
Hello
In a discussion yesterday the question came up if an internal changelog
topic can be enabled for compaction and deletion.
https://stackoverflow.com/questions/50622369/kafka-streams-is-it-possible-to-have-compact-delete-policy-on-state-stores
and
https://issues.apache.org/jira/browse/KAFKA-4
