You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/09/14 16:34:23 UTC
[flink] 12/16: Explicitly create topic
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 <ch...@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);
}