Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3992#discussion_r118731513
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
---
@@ -102,21 +99,21 @@
private static final long serialVersionUID = -6272159445203409112L;
- /** Configuration key for the number of retries for getting the
partition info */
+ /** Configuration key for the number of retries for getting the
partition info. */
public static final String GET_PARTITIONS_RETRIES_KEY =
"flink.get-partitions.retry";
/** Default number of retries for getting the partition info. One retry
means going through the full list of brokers */
public static final int DEFAULT_GET_PARTITIONS_RETRIES = 3;
//
------------------------------------------------------------------------
- /** The properties to parametrize the Kafka consumer and ZooKeeper
client */
+ /** The properties to parametrize the Kafka consumer and ZooKeeper
client. */
private final Properties kafkaProperties;
//
------------------------------------------------------------------------
/**
- * Creates a new Kafka streaming source consumer for Kafka 0.8.x
+ * Creates a new Kafka streaming source consumer for Kafka 0.8.x .
--- End diff --
Also has an extra space.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
