You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2024/04/11 22:04:49 UTC
(pekko-connectors-kafka) branch main updated: Update kafka-clients to 3.7.0 (#164)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new ab874c86 Update kafka-clients to 3.7.0 (#164)
ab874c86 is described below
commit ab874c865dc967dbbfc2c8c4c952214a0f6c8a2e
Author: scala-steward-asf[bot] <14...@users.noreply.github.com>
AuthorDate: Fri Apr 12 00:04:45 2024 +0200
Update kafka-clients to 3.7.0 (#164)
* Update kafka-clients to 3.7.0
* Update PartitionedSourceSpec.scala
---------
Co-authored-by: scala-steward-asf[bot] <14...@users.noreply.github.com>
Co-authored-by: PJ Fanning <pj...@users.noreply.github.com>
---
project/Versions.scala | 2 +-
.../scala/org/apache/pekko/kafka/internal/PartitionedSourceSpec.scala | 3 +++
2 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/project/Versions.scala b/project/Versions.scala
index 1872b50b..1bceebc7 100644
--- a/project/Versions.scala
+++ b/project/Versions.scala
@@ -26,7 +26,7 @@ object Versions {
val pekkoVersion = PekkoCoreDependency.version
// Keep .scala-steward.conf pin in sync
- val kafkaVersion = "3.0.2"
+ val kafkaVersion = "3.7.0"
val KafkaVersionForDocs = "30"
val scalaTestVersion = "3.2.18"
diff --git a/tests/src/test/scala/org/apache/pekko/kafka/internal/PartitionedSourceSpec.scala b/tests/src/test/scala/org/apache/pekko/kafka/internal/PartitionedSourceSpec.scala
index 2c62a215..8d998210 100644
--- a/tests/src/test/scala/org/apache/pekko/kafka/internal/PartitionedSourceSpec.scala
+++ b/tests/src/test/scala/org/apache/pekko/kafka/internal/PartitionedSourceSpec.scala
@@ -840,6 +840,9 @@ object PartitionedSourceSpec {
log.debug(s"resuming ${ps.mkString("(", ", ", ")")}")
tps.updateAndGet(unary(t => t ++ ps.filter(tp => t.contains(tp)).map(_ -> Resumed)))
}
+
+ override def clientInstanceId(d: java.time.Duration): org.apache.kafka.common.Uuid = ???
+ override def enforceRebalance(s: String): Unit = ???
}
private def unary[T](f: T => T) = new UnaryOperator[T] {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org