You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by pa...@apache.org on 2022/06/21 17:13:03 UTC

[beam] branch master updated (e747a18eb20 -> 316c969b9c3)

This is an automated email from the ASF dual-hosted git repository.

pabloem pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from e747a18eb20 Add unit testing for graphx/user.go (#21962)
     new 05ac1871766 21742 add warning for risky kafka configuration
     new 1058f069aa0 21742 run spotless
     new 316c969b9c3 Merge pull request #21899 from Beam/21742 add warning to risky kafka config

The 36336 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 37 ++++++++++++++++++++++
 .../org/apache/beam/sdk/io/kafka/KafkaIOTest.java  | 24 ++++++++++++++
 2 files changed, 61 insertions(+)