diff --git a/persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/KeySchema.scala b/persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/KeySchema.scala
index 459da3db..2155ed11 100644
--- a/persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/KeySchema.scala
+++ b/persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/KeySchema.scala
@@ -39,6 +39,7 @@ object KeySchema {
           |metadata TEXT,
           |PRIMARY KEY((application_id, group_id, segment), topic, partition, key)
           |)
+          |WITH compaction = {'class': 'org.apache.cassandra.db.compaction.LeveledCompactionStrategy'}
           |""".stripMargin
         ) >>
         session