[CALCITE-2913] Adapter for Apache Kafka

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.20.0
• Component/s: kafka-adapter
• Labels: pull-request-available
• Assignee: Mingmin Xu
• Reporter: Mingmin Xu
• Created: 11/Mar/19 21:47
• Updated: 24/Jun/19 15:01
• Resolved: 24/May/19 17:48

Description

Add a new adapter which exposes a Kafka topic into a Stream table, we've one version in our env and would like to share it if not duplicated.

Hint, we are actually extending it as a batch table, limiting to Stream table sounds more straight-forward to me as 1st step.

Issue Links

• blocks: CALCITE-3073 Support to consume from timestamp in KafkaAdapter
• blocks: CALCITE-3080 support user-specified row schema in KafkaAdapter
• links to: GitHub Pull Request #1127