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/17 10:53:00 UTC

[jira] [Assigned] (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:all-tabpanel ]

Stuart Perks reassigned SAMZA-398:
----------------------------------

    Assignee: Stuart Perks

> 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
>            Assignee: Stuart Perks
>            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)