flink里创建kafka topic
时间: 2023-07-02 09:12:25 浏览: 65
在 Flink 中创建 Kafka topic 可以使用 Kafka 命令行工具或者 Java 代码实现。以下是使用 Java 代码创建 Kafka topic 的示例:
```
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.NewTopic;
import java.util.Collections;
import java.util.Properties;
public class KafkaTopicCreator {
public static void main(String[] args) throws Exception {
// Kafka broker 地址列表
String bootstrapServers = "localhost:9092";
// Kafka topic 名称
String topicName = "mytopic";
// Kafka 分区数
int numPartitions = 1;
// Kafka 副本数
short replicationFactor = 1;
// 配置 Kafka 管理员客户端属性
Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
AdminClient adminClient = AdminClient.create(props);
// 创建 Kafka topic
NewTopic newTopic = new NewTopic(topicName, numPartitions, replicationFactor);
adminClient.createTopics(Collections.singleton(newTopic)).all().get();
System.out.println("Topic " + topicName + " created successfully.");
// 关闭 Kafka 管理员客户端
adminClient.close();
}
}
```
使用以上代码创建 Kafka topic,你需要在项目中添加以下依赖:
```
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>2.0.0</version>
</dependency>
```