[GitHub] [beam] damondouglas commented on issue #21414: Create KafkaIO SchemaTransform

[GitBox <gi...@apache.org>]

damondouglas commented on issue #21414:
URL: https://github.com/apache/beam/issues/21414#issuecomment-1164682826

   The output of this task is a The output of this task an implementation of Read and Write SchemaTransforms and their respective Configurations to support reading from and writing to Kafka.
   
   This task will be separated into four PRs to focus on Read and Write SchemaTransforms and their respective Configurations. See [BigQuerySchemaTransformReadProvider](https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySchemaTransformReadProvider.java) and [BigQuerySchemaTransformWriteConfiguration](https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySchemaTransformWriteConfiguration.java) as an example design pattern.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org