You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by en...@apache.org on 2025/11/28 10:48:10 UTC
(pekko-connectors-kafka) 02/10: try to fix compile issues
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 <pj...@users.noreply.github.com>
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: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org