Drop deprecated methods (#740)

Author: Z1kkurat

core/src/main/scala/com/evolutiongaming/kafka/flow/key/KeyDatabase.scala

@@ -20,10 +20,6 @@ trait KeyDatabase[F[_], K] {
 
   def all(applicationId: String, groupId: String, topicPartition: TopicPartition): Stream[F, K]
 
-  @deprecated("Use `toKeysOf` instead", "5.0.6")
-  def keysOf(implicit F: Monad[F], logOf: LogOf[F]): F[KeysOf[F, K]] =
-    logOf(KeyDatabase.getClass) map { implicit log => KeysOf(this) }
-
   def toKeysOf(implicit F: Monad[F], logOf: LogOf[F], logPrefix: LogPrefix[K]): F[KeysOf[F, K]] =
     logOf(KeyDatabase.getClass) map { implicit log => KeysOf.of(this) }
 }

core/src/main/scala/com/evolutiongaming/kafka/flow/key/Keys.scala

@@ -23,24 +23,6 @@ trait KeyWriter[F[_]] {
 }
 object Keys {
 
-  /** Creates a buffer for a given writer */
-  @deprecated("Use `of` instead", "5.0.6")
-  private[key] def apply[F[_]: Monad: Log, K](
-    key: K,
-    database: KeyDatabase[F, K]
-  ): Keys[F] = new Keys[F] {
-
-    def flush: F[Unit] = database.persist(key)
-
-    def delete(persist: Boolean): F[Unit] =
-      if (persist) {
-        database.delete(key) *> Log[F].info("deleted key")
-      } else {
-        ().pure[F]
-      }
-
-  }
-
   private[key] def of[F[_]: Monad: Log, K: LogPrefix](
     key: K,
     database: KeyDatabase[F, K]

core/src/main/scala/com/evolutiongaming/kafka/flow/key/KeysOf.scala

@@ -17,23 +17,9 @@ trait KeysOf[F[_], K] {
 }
 object KeysOf {
 
-  @deprecated("Use another `memory1` instead", "5.0.6")
-  def memory[F[_]: Sync: Log, K]: F[KeysOf[F, K]] =
-    KeyDatabase.memory[F, K].map(database => KeysOf.apply(database))
-
   def memory1[F[_]: Sync: Log, K: LogPrefix]: F[KeysOf[F, K]] =
     KeyDatabase.memory[F, K].map(database => KeysOf.of(database))
 
-  /** Creates `KeysOf` with a passed logger */
-  @deprecated("Use `of` instead", "5.0.6")
-  def apply[F[_]: Monad: Log, K](
-    database: KeyDatabase[F, K]
-  ): KeysOf[F, K] = new KeysOf[F, K] {
-    def apply(key: K) = Keys(key, database)
-    def all(applicationId: String, groupId: String, topicPartition: TopicPartition) =
-      database.all(applicationId, groupId, topicPartition)
-  }
-
   /** Creates `KeysOf` with a passed logger */
   def of[F[_]: Monad: Log, K: LogPrefix](
     database: KeyDatabase[F, K]

persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/journal/JournalSchema.scala

@@ -12,15 +12,6 @@ trait JournalSchema[F[_]] {
 }
 
 object JournalSchema {
-  @deprecated(
-    "Use the version with an explicit table name. This exists to preserve binary compatibility until the next major release",
-    since = "6.1.3"
-  )
-  def of[F[_]: Monad](
-    session: CassandraSession[F],
-    synchronize: CassandraSync[F],
-  ): JournalSchema[F] = of(session, synchronize, CassandraJournals.DefaultTableName)
-
   def of[F[_]: Monad](
     session: CassandraSession[F],
     synchronize: CassandraSync[F],

persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/key/KeySchema.scala

@@ -49,13 +49,4 @@ object KeySchema {
     }
   }
 
-  @deprecated(
-    "Use the version with an explicit table name. This exists to preserve binary compatibility until the next major release",
-    since = "6.1.3"
-  )
-  def of[F[_]: Monad](
-    session: CassandraSession[F],
-    synchronize: CassandraSync[F],
-  ): KeySchema[F] = of(session, synchronize, CassandraKeys.DefaultTableName)
-
 }

persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/snapshot/SnapshotSchema.scala

@@ -13,15 +13,6 @@ trait SnapshotSchema[F[_]] {
 
 object SnapshotSchema {
 
-  @deprecated(
-    "Use the version with an explicit table name. This exists to preserve binary compatibility until the next major release",
-    since = "6.1.3"
-  )
-  def of[F[_]: Monad](
-    session: CassandraSession[F],
-    synchronize: CassandraSync[F],
-  ): SnapshotSchema[F] = of(session, synchronize, CassandraSnapshots.DefaultTableName)
-
   def of[F[_]: Monad](
     session: CassandraSession[F],
     synchronize: CassandraSync[F],