You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Stuart Perks (Jira)" <ji...@apache.org> on 2021/04/13 13:14:00 UTC

[jira] [Commented] (SAMZA-398) Enable compression in Kafka checkpoint and changelog topics

    [ https://issues.apache.org/jira/browse/SAMZA-398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17320170#comment-17320170 ] 

Stuart Perks commented on SAMZA-398:
------------------------------------

Seems this was never done, will look to remove this forced NONE compression on Kafka Changelog now its upgraded much higher

> Enable compression in Kafka checkpoint and changelog topics
> -----------------------------------------------------------
>
>                 Key: SAMZA-398
>                 URL: https://issues.apache.org/jira/browse/SAMZA-398
>             Project: Samza
>          Issue Type: Bug
>          Components: kafka
>    Affects Versions: 0.8.0
>            Reporter: Chris Riccomini
>            Priority: Major
>
> Once KAFKA-1374 is committed, we should allow checkpoint and changelog messages in Kafka to be compressed. Right now, we explicitly force uncompressed messages in KafkaCheckpointManagerFactory and KafkaSystemFactory to prevent the log compaction from breaking.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)