This is an automated email from the ASF dual-hosted git repository. kenn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit 3a6100d7af5abd3655afe9e8cd52f406044979df Merge: b5ea07d77c0 152bcde49e4 Author: Kenneth Knowles <[email protected]> AuthorDate: Fri Jun 17 09:47:56 2022 -0700 Merge pull request #21783: Eliminate nullness errors in KafkaIO .../src/main/resources/beam/spotbugs-filter.xml | 7 + .../src/main/java/org/apache/beam/sdk/io/Read.java | 5 +- ...onfluentSchemaRegistryDeserializerProvider.java | 22 +-- .../beam/sdk/io/kafka/KafkaCheckpointMark.java | 5 +- .../beam/sdk/io/kafka/KafkaCommitOffset.java | 1 - .../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 67 +++++---- .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 149 ++++++++++++++------- .../org/apache/beam/sdk/io/kafka/KafkaIOUtils.java | 3 +- .../org/apache/beam/sdk/io/kafka/KafkaRecord.java | 5 +- .../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 10 +- .../beam/sdk/io/kafka/KafkaSourceDescriptor.java | 47 ++++--- .../beam/sdk/io/kafka/KafkaUnboundedReader.java | 63 ++++++--- .../beam/sdk/io/kafka/KafkaUnboundedSource.java | 17 ++- .../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 67 +++++---- .../sdk/io/kafka/LocalDeserializerProvider.java | 11 +- .../beam/sdk/io/kafka/ProducerRecordCoder.java | 22 +-- .../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 130 ++++++++++-------- .../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 56 +++++--- .../beam/sdk/io/kafka/TopicPartitionCoder.java | 1 - .../sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java | 16 +-- .../io/kafka/LocalDeserializerProviderTest.java | 14 +- .../beam/sdk/io/kafka/ReadFromKafkaDoFnTest.java | 2 + .../beam/sdk/io/kafka/TopicPartitionCoderTest.java | 1 - .../io/kafka/WatchKafkaTopicPartitionDoFnTest.java | 1 - 24 files changed, 446 insertions(+), 276 deletions(-)
