[ https://issues.apache.org/jira/browse/KAFKA-3252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15373182#comment-15373182 ]
Ashish K Singh commented on KAFKA-3252: --------------------------------------- [~junrao] [~omkreddy] what should be the expected behavior in case re-compressed message exceed max message size? Waiting on feedback [here|https://github.com/apache/kafka/pull/1010#discussion_r55396575]. > compression type for a topic should be used during log compaction > ------------------------------------------------------------------ > > Key: KAFKA-3252 > URL: https://issues.apache.org/jira/browse/KAFKA-3252 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.9.0.0 > Reporter: Jun Rao > Assignee: Ashish K Singh > Fix For: 0.10.1.0 > > > Currently, the broker uses the specified compression type in a topic for > newly published messages. However, during log compaction, it still uses the > compression codec in the original message. To be consistent, it seems that we > should use the compression type in a topic when copying the messages to new > log segments. -- This message was sent by Atlassian JIRA (v6.3.4#6332)