Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4915#discussion_r148441559
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011Test.java
---
@@ -61,7 +61,7 @@
* IT cases for the {@link FlinkKafkaProducer011}.
*/
@SuppressWarnings("serial")
-public class FlinkKafkaProducer011Tests extends KafkaTestBase {
+public class FlinkKafkaProducer011Test extends KafkaTestBase {
--- End diff --
I'm leaning towards `*ITCase` here, since it is indeed an integration test
with Kafka.
---
