Also include KafkaIO

sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java

@@ -63,8 +63,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned
+ * For any significant updates to this I/O connector, please consider involving corresponding code
+ * reviewers mentioned
  * <a href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/google-cloud-platform/OWNERS

@@ -1,5 +1,4 @@
 # See the OWNERS docs at https://s.apache.org/beam-owners
-# Please involve following reviewers (Github IDs) for code reviews related to respective connectors.
 
 reviewers (BigTableIO) :
   - igorbernstein2

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java

@@ -460,8 +460,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned <a
+ * For any significant updates to this I/O connector, please consider involving corresponding code
+ * reviewers mentioned <a
  * href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java

@@ -174,8 +174,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned <a
+ * For any significant updates to this I/O connector, please consider involving corresponding code
+ * reviewers mentioned <a
  * href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java

@@ -236,8 +236,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned
+ * For any significant updates to this I/O connector, please consider involving corresponding code
+ * reviewers mentioned
  * <a href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java

@@ -99,8 +99,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned <a
+ * For any significant updates to this I/O connector, please consider involving corresponding code
+ * reviewers mentioned <a
  * href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java

@@ -38,8 +38,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned <a
+ * For any significant updates to this I/O connector, please consider involving corresponding code
+ * reviewers mentioned <a
  * href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java

@@ -356,8 +356,8 @@
  *
  * <h3>Updates to the I/O connector code</h3>
  *
- * For any updates to this I/O connector, please consider involving corresponding code reviewers
- * mentioned <a
+ * For any significant significant updates to this I/O connector, please consider involving
+ * corresponding code reviewers mentioned <a
  * href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
  * here</a>.
  */

sdks/java/io/kafka/OWNERS

@@ -0,0 +1,7 @@
+# See the OWNERS docs at https://s.apache.org/beam-owners
+
+reviewers:
+  - aromanenko-dev
+  - chamikaramj
+  - lukecwik
+  - johnjcasey

sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java

@@ -533,6 +533,13 @@
  * ensure that the version included with the application is compatible with the version of your
  * Kafka cluster. Kafka client usually fails to initialize with a clear error message in case of
  * incompatibility.
+ *
+ * <h3>Updates to the I/O connector code</h3>
+ *
+ * For any significant significant updates to this I/O connector, please consider involving
+ * corresponding code reviewers mentioned <a
+ * href="https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/OWNERS">
+ * here</a>.
  */
 @Experimental(Kind.SOURCE_SINK)
 @SuppressWarnings({

sdks/python/OWNERS

@@ -1,5 +1,4 @@
 # See the OWNERS docs at https://s.apache.org/beam-owners
-# Please involve following reviewers (Github IDs) for code reviews related to respective connectors.
 
 reviewers (all changes):
   - aaltay

sdks/python/apache_beam/io/gcp/bigquery.py

@@ -268,8 +268,8 @@ def compute_table_name(row):
 
 **Updates to the I/O connector code**
 
-For any updates to this I/O connector, please consider involving corresponding
-code reviewers mentioned in
+For any significant updates to this I/O connector, please consider involving
+corresponding code reviewers mentioned in
 https://github.com/apache/beam/blob/master/sdks/python/OWNERS
 """
 

sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py

@@ -23,8 +23,8 @@
 
 **Updates to the I/O connector code**
 
-For any updates to this I/O connector, please consider involving corresponding
-code reviewers mentioned in
+For any significant updates to this I/O connector, please consider involving
+corresponding code reviewers mentioned in
 https://github.com/apache/beam/blob/master/sdks/python/OWNERS
 """
 # pytype: skip-file

sdks/python/apache_beam/io/gcp/gcsfilesystem.py

@@ -19,8 +19,8 @@
 
 **Updates to the I/O connector code**
 
-For any updates to this I/O connector, please consider involving corresponding
-code reviewers mentioned in
+For any significant updates to this I/O connector, please consider involving
+corresponding code reviewers mentioned in
 https://github.com/apache/beam/blob/master/sdks/python/OWNERS
 """
 
@@ -33,7 +33,7 @@
 from apache_beam.io.filesystem import CompressionTypes
 from apache_beam.io.filesystem import FileMetadata
 from apache_beam.io.filesystem import FileSystem
-from apache_beam.io.gcp import gcsio
+from apache_beam.io.gcp import gcsio<a
 
 __all__ = ['GCSFileSystem']
 

sdks/python/apache_beam/io/gcp/gcsio.py

@@ -22,8 +22,8 @@
 
 **Updates to the I/O connector code**
 
-For any updates to this I/O connector, please consider involving corresponding
-code reviewers mentioned in
+For any significant updates to this I/O connector, please consider involving
+corresponding code reviewers mentioned in
 https://github.com/apache/beam/blob/master/sdks/python/OWNERS
 """
 

sdks/python/apache_beam/io/gcp/pubsub.py

@@ -24,8 +24,8 @@
 
 **Updates to the I/O connector code**
 
-For any updates to this I/O connector, please consider involving corresponding
-code reviewers mentioned in
+For any significant updates to this I/O connector, please consider involving
+corresponding code reviewers mentioned in
 https://github.com/apache/beam/blob/master/sdks/python/OWNERS
 """