[jira] [Created] (FLINK-22610) The test-jar of flink-connector-kafka should include all test classes

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-22610) The test-jar of flink-connector-kafka should include all test classes

Shang Yuanchun (Jira)
LIU Xiao created FLINK-22610:
--------------------------------

             Summary: The test-jar of flink-connector-kafka should include all test classes
                 Key: FLINK-22610
                 URL: https://issues.apache.org/jira/browse/FLINK-22610
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
    Affects Versions: 1.12.3, 1.13.0
            Reporter: LIU Xiao


The test-jar of old kafka connector (flink-connector-kafka-base and flink-connector-kafka-0.11) includes convenient utility classes (KafkaTestEnvironment and KafkaTestEnvironmentImpl, etc.) to start an embedded kafka in unit test, and we used the utility classes to build some test cases for our project.

Now the utility classes other than KafkaTestEnvironmentImpl seem to be gone in test-jar of new kafka connector (flink-connector-kafka), and I find that is because they are not included in the configuration of maven-jar-plugin in pom.xml:
{code:java}
<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-jar-plugin</artifactId>
            <executions>
                <execution>
                    <goals>
                        <goal>test-jar</goal>
                    </goals>
                    <configuration>
                        <includes>
                            <include>**/KafkaTestEnvironmentImpl*</include>
                            <include>META-INF/LICENSE</include>
                            <include>META-INF/NOTICE</include>
                        </includes>
                    </configuration>
                </execution>
            </executions>
        </plugin>
{code}
This configuration seems to be inherited from flink-connector-kafka-0.11, but I think the configuration of flink-connector-kafka-base should be used:
{code:java}
  <build>
    <plugins>
      <plugin>
        <artifactId>maven-jar-plugin</artifactId>
        <executions>
          <execution>
            <goals>
              <goal>test-jar</goal>
            </goals>
          </execution>
        </executions>
      </plugin>
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)