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 <arkadiu...@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);