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

AdminClient.create介绍

暂无

代码示例

代码示例来源：origin: com.cerner.common.kafka/common-kafka-admin

private AdminClient getAdminClient() {
  if (adminClient == null)
    adminClient = AdminClient.create(properties);
  return adminClient;
}

代码示例来源：origin: vakinge/jeesuite-libs

public KafkaConsumerCommand(String bootstrapServer) {
  this.bootstrapServer = bootstrapServer;
  Properties props = new Properties();
  props.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, bootstrapServer);
  adminClient = AdminClient.create(props);
}

代码示例来源：origin: kloiasoft/eventapis

@Bean("adminToolsClient")
public kafka.admin.AdminClient adminToolsClient(@Autowired @Qualifier("kafkaAdminProperties") Properties kafkaAdminProperties) {
  return kafka.admin.AdminClient.create(kafkaAdminProperties);
}

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

public void init(){
  prop = new Properties();
  prop.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaConfig.getBrokers());
  prop.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
      "org.apache.kafka.common.serialization.StringSerializer");
  prop.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
      "org.apache.kafka.common.serialization.StringSerializer");
  producer = new KafkaProducer(prop);
  log.info("Kafka initing...");
  kafkaAdminClient = AdminClient.create(prop);
}

代码示例来源：origin: apache/samza

/**
 * Delete records up to (and including) the provided ssp offsets for
 * all system stream partitions specified in the map.
 * This only works with Kafka cluster 0.11 or later. Otherwise it's a no-op.
 * @param offsets specifies up to what offsets the messages should be deleted
 */
@Override
public void deleteMessages(Map<SystemStreamPartition, String> offsets) {
 if (deleteCommittedMessages) {
  if (adminClientForDelete == null) {
   adminClientForDelete = kafka.admin.AdminClient.create(createAdminClientProperties());
  }
  KafkaSystemAdminUtilsScala.deleteMessages(adminClientForDelete, offsets);
  deleteMessageCalled = true;
 }
}

代码示例来源：origin: org.apache.samza/samza-kafka

/**
 * Delete records up to (and including) the provided ssp offsets for
 * all system stream partitions specified in the map.
 * This only works with Kafka cluster 0.11 or later. Otherwise it's a no-op.
 * @param offsets specifies up to what offsets the messages should be deleted
 */
@Override
public void deleteMessages(Map<SystemStreamPartition, String> offsets) {
 if (deleteCommittedMessages) {
  if (adminClient == null) {
   adminClient = AdminClient.create(createAdminClientProperties());
  }
  KafkaSystemAdminUtilsScala.deleteMessages(adminClient, offsets);
  deleteMessageCalled = true;
 }
}

代码示例来源：origin: org.apache.samza/samza-kafka_2.11

/**
 * Delete records up to (and including) the provided ssp offsets for
 * all system stream partitions specified in the map.
 * This only works with Kafka cluster 0.11 or later. Otherwise it's a no-op.
 * @param offsets specifies up to what offsets the messages should be deleted
 */
@Override
public void deleteMessages(Map<SystemStreamPartition, String> offsets) {
 if (deleteCommittedMessages) {
  if (adminClient == null) {
   adminClient = AdminClient.create(createAdminClientProperties());
  }
  KafkaSystemAdminUtilsScala.deleteMessages(adminClient, offsets);
  deleteMessageCalled = true;
 }
}