[jira] [Created] (FLINK-7238) Kafka integration tests do not restart Kafka brokers properly

[Shang Yuanchun (Jira)]

Piotr Nowojski created FLINK-7238:
-------------------------------------

             Summary: Kafka integration tests do not restart Kafka brokers properly
                 Key: FLINK-7238
                 URL: https://issues.apache.org/jira/browse/FLINK-7238
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector
            Reporter: Piotr Nowojski


Integrations tests that restart a broker (like KafkaXYITCase or KafkaXYProducerITCase), do not ends in the same state as they started, leaving behind slightly degenerated Kafka cluster.

It seems like each such tests brakes permanently one Kafka broker. As long as in the scope of one test file, there are more Kafka brokers (currently 3) then tests that fail a Kafka broker all tests will pass. If there are 3 or more such tests cases, tests become unstable and can crash with different errors or even live/dead lock.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)