Skip to content

Releases: evolution-gaming/kafka-flow

v5.0.3

29 Oct 13:19
14fbc2d
Compare
Choose a tag to compare

What's Changed

Full Changelog: v5.0.2...v5.0.3

v5.0.2

25 Oct 12:37
e6205b3
Compare
Choose a tag to compare
  • Update kafka-journal to 4.1.0

Full Changelog: v5.0.1...v5.0.2

v5.0.1

17 Oct 16:48
9fe7403
Compare
Choose a tag to compare

What's Changed

  • Commit actual latest offsets on partition flow release when commitOnRevoke and flushOnRevoke are enabled by @i-surkov in #641

New Contributors

Full Changelog: v5.0.0...v5.0.1

v5.0.0

08 Oct 16:48
b5dafad
Compare
Choose a tag to compare

Breaking changes

  • dropped APIs marked for deprecation earlier:
    • com.evolutiongaming.kafka.flow.cassandra. CassandraHealthCheckOf. Instead, use com.evolution.kafka.flow.cassandra.CassandraHealthCheckOf
    • com.evolutiongaming.kafka.flow.cassandra. CassandraModule. Instead, use com.evolution.kafka.flow.cassandra.CassandraModule
    • factory methods in com.evolutiongaming.kafka.flow.cassandra.CassandraPersistence that used classes from kafka-journal as parameters: withSchemaF, withSchema and truncate. Use alternatives with the same name taking scassandra.CassandraSession as parameter
    • factory methods in com.evolutiongaming.kafka.flow.journal.CassandraJournals that used classes from kafka-journal as parameters: withSchema and truncate. Use alternatives with the same name taking scassandra.CassandraSession as parameter
    • factory method com.evolutiongaming.kafka.flow.journal.JournalSchema#apply that used classes from kafka-journal as parameters. Use the alternative method JournalSchema#of taking scassandra.CassandraSession as parameter
    • factory methods in com.evolutiongaming.kafka.flow.key.CassandraKeys that used classes from kafka-journal as parameters: two class constructors, withSchema, truncate. Use other primary constructors and method alternatives with the same name taking scassandra classes as parameters
    • factory method com.evolutiongaming.kafka.flow.key.KeySchema#apply that used classes from kafka-journal as parameters. Use the alternative method KeySchema#of taking scassandra.CassandraSession as parameter
    • dropped com.evolutiongaming.kafka.flow.migration helper object that facilitated conversion from kafka-journal FromBytes/ToBytes to skafka FromBytes/ToBytes. Instead, it's advised to implement skafka instances directly without conversions
    • factory methods in com.evolutiongaming.kafka.flow.snapshot.CassandraSnapshots that used classes from kafka-journal as parameters: a class constructor, withSchema, truncate. Use the other primary constructor and method alternatives with the same name taking scassandra classes as parameters
    • com.evolutiongaming.kafka.flow.kafkapersistence#caching taking an instance of ProducerOf. Instead, pass a single instance of Producer explicitly to avoid creating a new producer for each partition
    • com.evolutiongaming.kafka.flow.kafkapersistence.KafkaPersistenceModuleOf#caching taking an instance of ProducerOf. Instead, pass a single instance of Producer explicitly to avoid creating a new producer for each partition

Updated major dependencies:

  • skafka: 16.0.3 -> 17.1.2
  • kafka-journal: 3.4.1 -> 4.0.2

What's Changed

  • Bump skafka and kafka-journal libs, drop deprecates by @Phill101 in #639

Full Changelog: v4.6.0...v5.0.0

v4.6.0

30 Sep 11:46
9049272
Compare
Choose a tag to compare

What's Changed

  • Make keys DDL use LeveledCompactionStrategy by default by @Z1kkurat in #636

Full Changelog: v4.5.1...v4.6.0

v0.14.0

30 Sep 11:53
eaef829
Compare
Choose a tag to compare

What's Changed

  • Make keys DDL use LeveledCompactionStrategy by default [CE2] by @Z1kkurat in #637

Full Changelog: v0.13.2...v0.14.0

v4.5.1

14 Sep 17:06
9c75fae
Compare
Choose a tag to compare

What's Changed

New Contributors

Full Changelog: v4.5.0...v4.5.1

v4.5.0

15 Aug 15:27
8ff0ff9
Compare
Choose a tag to compare

What's Changed

  • Add a flag to enable ignoring errors during additional state persists. by @vilunov in #625

Full Changelog: v4.4.1...v4.5.0

v4.4.1

23 Jul 09:35
8916d49
Compare
Choose a tag to compare

What's Changed

Full Changelog: v4.3.2...v4.4.1

v4.3.2

12 Jul 10:20
61369a6
Compare
Choose a tag to compare

Full Changelog: v4.3.1...v4.3.2