v5.0.0
Breaking changes
- dropped APIs marked for deprecation earlier:
com.evolutiongaming.kafka.flow.cassandra. CassandraHealthCheckOf
. Instead, usecom.evolution.kafka.flow.cassandra.CassandraHealthCheckOf
com.evolutiongaming.kafka.flow.cassandra. CassandraModule
. Instead, usecom.evolution.kafka.flow.cassandra.CassandraModule
- factory methods in
com.evolutiongaming.kafka.flow.cassandra.CassandraPersistence
that used classes fromkafka-journal
as parameters:withSchemaF
,withSchema
andtruncate
. Use alternatives with the same name takingscassandra.CassandraSession
as parameter - factory methods in
com.evolutiongaming.kafka.flow.journal.CassandraJournals
that used classes fromkafka-journal
as parameters:withSchema
andtruncate
. Use alternatives with the same name takingscassandra.CassandraSession
as parameter - factory method
com.evolutiongaming.kafka.flow.journal.JournalSchema#apply
that used classes fromkafka-journal
as parameters. Use the alternative methodJournalSchema#of
takingscassandra.CassandraSession
as parameter - factory methods in
com.evolutiongaming.kafka.flow.key.CassandraKeys
that used classes fromkafka-journal
as parameters: two class constructors,withSchema
,truncate
. Use other primary constructors and method alternatives with the same name takingscassandra
classes as parameters - factory method
com.evolutiongaming.kafka.flow.key.KeySchema#apply
that used classes fromkafka-journal
as parameters. Use the alternative methodKeySchema#of
takingscassandra.CassandraSession
as parameter - dropped
com.evolutiongaming.kafka.flow.migration
helper object that facilitated conversion fromkafka-journal
FromBytes
/ToBytes
toskafka
FromBytes
/ToBytes
. Instead, it's advised to implementskafka
instances directly without conversions - factory methods in
com.evolutiongaming.kafka.flow.snapshot.CassandraSnapshots
that used classes fromkafka-journal
as parameters: a class constructor,withSchema
,truncate
. Use the other primary constructor and method alternatives with the same name takingscassandra
classes as parameters com.evolutiongaming.kafka.flow.kafkapersistence#caching
taking an instance ofProducerOf
. Instead, pass a single instance ofProducer
explicitly to avoid creating a new producer for each partitioncom.evolutiongaming.kafka.flow.kafkapersistence.KafkaPersistenceModuleOf#caching
taking an instance ofProducerOf
. Instead, pass a single instance ofProducer
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
Full Changelog: v4.6.0...v5.0.0