RestrictedConsumer: correct deprecation since version (#1197)

akka · Sep 8, 2020 · e250df6 · e250df6
1 parent 89b116b
commit e250df6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/akka/kafka/RestrictedConsumer.scala b/core/src/main/scala/akka/kafka/RestrictedConsumer.scala
@@ -38,7 +38,7 @@ final class RestrictedConsumer(consumer: Consumer[_, _], duration: java.time.Dur
    * See [[org.apache.kafka.clients.consumer.KafkaConsumer#committed(TopicPartition,java.time.Duration)]]
    */
   @silent
-  @deprecated("use `committed(java.util.Set[TopicPartition])`", "2.1.0")
+  @deprecated("use `committed(java.util.Set[TopicPartition])`", "2.0.5")
   def committed(tp: TopicPartition): OffsetAndMetadata = consumer.committed(tp, duration)
 
   /**