Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5056#discussion_r152761700
--- Diff:
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
---
@@ -163,14 +203,14 @@ protected void
setRowtimeAttributeDescriptors(List<RowtimeAttributeDescriptor> r
//////// ABSTRACT METHODS FOR SUBCLASSES
/**
- * Returns the version-specific Kafka consumer.
+ * Create a version-specific Kafka consumer.
--- End diff --
Create -> Creates
---
