[flink] 12/16: Explicitly create topic

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch pull/19923/head
in repository https://gitbox.apache.org/repos/asf/flink.git

commit b193c84d83fd8d4bb35b0c7af4aee64382fbd766
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Wed Sep 14 17:59:25 2022 +0200

    Explicitly create topic
---
 .../flink-sql-client-test/src/test/java/SqlClientITCase.java             | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
 
b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
index bd7ce195699..212c54e8f2e 100644
--- 
a/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
+++ 
b/flink-end-to-end-tests/flink-sql-client-test/src/test/java/SqlClientITCase.java
@@ -238,6 +238,7 @@ public class SqlClientITCase {
 
     public void sendMessages(String topic, String... messages) {
         KafkaContainerClient kafkaClient = new KafkaContainerClient(KAFKA);
+        kafkaClient.createTopic(1, 1, topic);
         kafkaClient.sendMessages(topic, new StringSerializer(), messages);
     }