Description
This is a known issue, but opening a ticket to track.
If you try to compact a topic that has compressed messages you will run into
various exceptions - typically because during iteration we advance the
position based on the decompressed size of the message. I have a bunch of
stack traces, but it should be straightforward to reproduce.
Attachments
Attachments
Issue Links
- is depended upon by
-
KAFKA-1944 Rename LogCleaner and related classes to LogCompactor
- Resolved
-
SAMZA-388 Log compaction on checkpoint topics fails with compression
- Resolved
- is related to
-
SAMZA-398 Enable compression in Kafka checkpoint and changelog topics
- Resolved
-
SAMZA-586 LoggedStore can send compressed messages to log-compacted Kafka topic
- Resolved
-
KAFKA-1499 Broker-side compression configuration
- Resolved
- relates to
-
KAFKA-1581 Log cleaner should have an option to ignore messages without keys
- Resolved