本文整理了Java中kafka.admin.AdminClient.createSimplePlaintext()方法的一些代码示例，展示了AdminClient.createSimplePlaintext()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AdminClient.createSimplePlaintext()方法的具体详情如下：
包路径：kafka.admin.AdminClient
类名称：AdminClient
方法名：createSimplePlaintext

AdminClient.createSimplePlaintext介绍

暂无

代码示例

代码示例来源：origin: org.apache.kafka/kafka_2.10

parseArguments(args);
adminClient = AdminClient.createSimplePlaintext(options.valueOf(bootstrapServerOption));
final String groupId = options.valueOf(applicationIdOption);
if (!adminClient.describeConsumerGroup(groupId).consumers().get().isEmpty()) {

代码示例来源：origin: confluentinc/kafka-streams-examples

final AdminClient adminClient = AdminClient.createSimplePlaintext(CLUSTER.bootstrapServers());
while (!adminClient.describeConsumerGroup(applicationId, 0).consumers().get().isEmpty()) {
 Utils.sleep(50);

代码示例来源：origin: gnuhpc/Kafka-zk-restapi

public AdminClient createAdminClient() {
    return AdminClient.createSimplePlaintext(getKafkaConfig().getBrokers());
  }
}