kafka学习笔记.docx
Topic的增删改查
importorg.apache.kafka.clients.admin.*;
importjava.util.Arrays;
importjava.util.Map;
importjava.util.Properties;
importjava.util.Set;
importjava.util.concurrent.ExecutionException;
publicclassKafkaTopicDml{
publicstaticvoidmain(String[]args){
Propertiesprops=
下载地址
用户评论
