This is an automated email from the ASF dual-hosted git repository. engelen pushed a commit to branch update/kafka-clients-4.0.0 in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit 0447290293e589b64ed4c2e95193d177d9055ec8 Author: PJ Fanning <[email protected]> AuthorDate: Wed Mar 26 13:03:05 2025 +0100 try to fix compile issues --- core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala | 6 ------ 1 file changed, 6 deletions(-) diff --git a/core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala b/core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala index fcaccf60..1b5c2f14 100644 --- a/core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala +++ b/core/src/main/scala/org/apache/pekko/kafka/RestrictedConsumer.scala @@ -43,12 +43,6 @@ final class RestrictedConsumer(consumer: Consumer[_, _], duration: java.time.Dur def commitSync(offsets: java.util.Map[TopicPartition, OffsetAndMetadata]): Unit = consumer.commitSync(offsets, duration) - /** - * See [[org.apache.kafka.clients.consumer.KafkaConsumer#committed(TopicPartition,java.time.Duration)]] - */ - @deprecated("use `committed(java.util.Set[TopicPartition])`", "Alpakka Kafka 2.0.5") - def committed(tp: TopicPartition): OffsetAndMetadata = consumer.committed(tp, duration) - /** * See [[org.apache.kafka.clients.consumer.KafkaConsumer#committed(java.util.Set[TopicPartition],java.time.Duration)]] */ --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
