[beam] branch master updated: [BEAM-13526] Kafka.IO: make DeserializerProvider a public interface (#16339)

[aromanenko]

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);