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 a281570c992e2bf93ec5cd3dccab473b2cdbcfc2 Author: PJ Fanning <[email protected]> AuthorDate: Wed Mar 26 13:14:19 2025 +0100 Update ConsumerResetProtection.scala --- .../scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala b/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala index 504053db..d7d4fa1a 100644 --- a/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala +++ b/core/src/main/scala/org/apache/pekko/kafka/internal/ConsumerResetProtection.scala @@ -68,7 +68,7 @@ object ConsumerResetProtection { .toMap .asJava - new ConsumerRecords[K, V](safe) + new ConsumerRecords[K, V](safe, java.util.Collections.emptyMap()) } /** --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
