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

KafkaConsumerProperties.isAutoRebalanceEnabled介绍

暂无

代码示例

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka

private Collection<PartitionInfo> getPartitionInfo(String topic,
    final ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties,
    final ConsumerFactory<?, ?> consumerFactory, int partitionCount) {
  return provisioningProvider.getPartitionsForTopic(partitionCount,
      extendedConsumerProperties.getExtension().isAutoRebalanceEnabled(),
      () -> {
        try (Consumer<?, ?> consumer = consumerFactory.createConsumer()) {
          List<PartitionInfo> partitionsFor = consumer.partitionsFor(topic);
          return partitionsFor;
        }
      }, topic);
}

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-kafka

private Collection<PartitionInfo> getPartitionInfo(String topic,
    final ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties,
    final ConsumerFactory<?, ?> consumerFactory, int partitionCount) {
  return provisioningProvider.getPartitionsForTopic(partitionCount,
      extendedConsumerProperties.getExtension().isAutoRebalanceEnabled(),
      () -> {
        try (Consumer<?, ?> consumer = consumerFactory.createConsumer()) {
          List<PartitionInfo> partitionsFor = consumer.partitionsFor(topic);
          return partitionsFor;
        }
      }, topic);
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka-core

ConsumerDestination consumerDestination = new KafkaConsumerDestination(name);
try (AdminClient adminClient = createAdminClient()) {
  createTopic(adminClient, name, partitionCount, properties.getExtension().isAutoRebalanceEnabled(),
      properties.getExtension().getAdmin());
  if (this.configurationProperties.isAutoCreateTopics()) {

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-kafka

ConsumerDestination consumerDestination = new KafkaConsumerDestination(name);
try (AdminClient adminClient = createAdminClient()) {
  createTopic(adminClient, name, partitionCount, properties.getExtension().isAutoRebalanceEnabled(),
      properties.getExtension().getTopic());
  if (this.configurationProperties.isAutoCreateTopics()) {

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka11-core

@Override
public ConsumerDestination provisionConsumerDestination(final String name, final String group, ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  KafkaTopicUtils.validateTopicName(name);
  boolean anonymous = !StringUtils.hasText(group);
  Assert.isTrue(!anonymous || !properties.getExtension().isEnableDlq(),
      "DLQ support is not available for anonymous subscriptions");
  if (properties.getInstanceCount() == 0) {
    throw new IllegalArgumentException("Instance count cannot be zero");
  }
  int partitionCount = properties.getInstanceCount() * properties.getConcurrency();
  createTopicsIfAutoCreateEnabledAndAdminUtilsPresent(name, partitionCount, properties.getExtension().isAutoRebalanceEnabled());
  if (this.configurationProperties.isAutoCreateTopics() && adminUtilsOperation != null) {
    final ZkUtils zkUtils = ZkUtils.apply(this.configurationProperties.getZkConnectionString(),
        this.configurationProperties.getZkSessionTimeout(),
        this.configurationProperties.getZkConnectionTimeout(),
        JaasUtils.isZkSecurityEnabled());
    int partitions = adminUtilsOperation.partitionSize(name, zkUtils);
    if (properties.getExtension().isEnableDlq() && !anonymous) {
      String dlqTopic = StringUtils.hasText(properties.getExtension().getDlqName()) ?
          properties.getExtension().getDlqName() : "error." + name + "." + group;
      createTopicAndPartitions(dlqTopic, partitions, properties.getExtension().isAutoRebalanceEnabled());
      return new KafkaConsumerDestination(name, partitions, dlqTopic);
    }
    return new KafkaConsumerDestination(name, partitions);
  }
  return new KafkaConsumerDestination(name);
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka-core

private ConsumerDestination createDlqIfNeedBe(AdminClient adminClient, String name, String group,
                      ExtendedConsumerProperties<KafkaConsumerProperties> properties,
                      boolean anonymous, int partitions) {
  if (properties.getExtension().isEnableDlq() && !anonymous) {
    String dlqTopic = StringUtils.hasText(properties.getExtension().getDlqName()) ?
        properties.getExtension().getDlqName() : "error." + name + "." + group;
    try {
      createTopicAndPartitions(adminClient, dlqTopic, partitions,
          properties.getExtension().isAutoRebalanceEnabled(), properties.getExtension().getAdmin());
    }
    catch (Throwable throwable) {
      if (throwable instanceof Error) {
        throw (Error) throwable;
      }
      else {
        throw new ProvisioningException("provisioning exception", throwable);
      }
    }
    return new KafkaConsumerDestination(name, partitions, dlqTopic);
  }
  return null;
}

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-kafka

private ConsumerDestination createDlqIfNeedBe(AdminClient adminClient, String name, String group,
                      ExtendedConsumerProperties<KafkaConsumerProperties> properties,
                      boolean anonymous, int partitions) {
  if (properties.getExtension().isEnableDlq() && !anonymous) {
    String dlqTopic = StringUtils.hasText(properties.getExtension().getDlqName()) ?
        properties.getExtension().getDlqName() : "error." + name + "." + group;
    try {
      createTopicAndPartitions(adminClient, dlqTopic, partitions,
          properties.getExtension().isAutoRebalanceEnabled(), properties.getExtension().getTopic());
    }
    catch (Throwable throwable) {
      if (throwable instanceof Error) {
        throw (Error) throwable;
      }
      else {
        throw new ProvisioningException("provisioning exception", throwable);
      }
    }
    return new KafkaConsumerDestination(name, partitions, dlqTopic);
  }
  return null;
}

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka11

extendedConsumerProperties.getExtension().isAutoRebalanceEnabled(),
    new Callable<Collection<PartitionInfo>>() {
if (extendedConsumerProperties.getExtension().isAutoRebalanceEnabled() ||
    extendedConsumerProperties.getInstanceCount() == 1) {
  listenedPartitions = allPartitions;
    listenedPartitions);
final ContainerProperties containerProperties = anonymous
    || extendedConsumerProperties.getExtension().isAutoRebalanceEnabled()
        ? new ContainerProperties(destination.getName())
        : new ContainerProperties(topicPartitionInitialOffsets);

代码示例来源：origin: spring-cloud/spring-cloud-stream-binder-kafka

"Cannot use a pattern with multiplexed destinations; "
    + "use the regex pattern to specify multiple topics instead");
boolean groupManagement = extendedConsumerProperties.getExtension().isAutoRebalanceEnabled();
if (!extendedConsumerProperties.isMultiplex()) {
  listenedPartitions.addAll(processTopic(consumerGroup, extendedConsumerProperties, consumerFactory,
    listenedPartitions);
final ContainerProperties containerProperties = anonymous
    || extendedConsumerProperties.getExtension().isAutoRebalanceEnabled()
        ? usingPatterns
            ? new ContainerProperties(Pattern.compile(topics[0]))

代码示例来源：origin: org.springframework.cloud/spring-cloud-stream-binder-kafka

"Cannot use a pattern with multiplexed destinations; "
    + "use the regex pattern to specify multiple topics instead");
boolean groupManagement = extendedConsumerProperties.getExtension().isAutoRebalanceEnabled();
if (!extendedConsumerProperties.isMultiplex()) {
  listenedPartitions.addAll(processTopic(consumerGroup, extendedConsumerProperties, consumerFactory,
    listenedPartitions);
final ContainerProperties containerProperties = anonymous
    || extendedConsumerProperties.getExtension().isAutoRebalanceEnabled()
        ? usingPatterns
            ? new ContainerProperties(Pattern.compile(topics[0]))