You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2021/12/28 09:29:01 UTC
[beam] branch master updated: [BEAM-13526] Kafka.IO: make DeserializerProvider a public interface (#16339)
This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new f8b5d01 [BEAM-13526] Kafka.IO: make DeserializerProvider a public interface (#16339)
f8b5d01 is described below
commit f8b5d01077de9eee19a033b82494f7168c43ae94
Author: Arkadiusz Gasiński <ar...@gmail.com>
AuthorDate: Tue Dec 28 10:27:54 2021 +0100
[BEAM-13526] Kafka.IO: make DeserializerProvider a public interface (#16339)
---
.../main/java/org/apache/beam/sdk/io/kafka/DeserializerProvider.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/DeserializerProvider.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/DeserializerProvider.java
index db3ccbe..08fa07f 100644
--- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/DeserializerProvider.java
+++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/DeserializerProvider.java
@@ -27,7 +27,7 @@ import org.apache.kafka.common.serialization.Deserializer;
/** Provides a configured {@link Deserializer} instance and its associated {@link Coder}. */
@Experimental(Kind.SOURCE_SINK)
-interface DeserializerProvider<T> extends Serializable {
+public interface DeserializerProvider<T> extends Serializable {
Deserializer<T> getDeserializer(Map<String, ?> configs, boolean isKey);