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=