org.springframework.cloud.stream.binder.kafka.properties.KafkaConsumerProperties.isEnableDlq()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(11.7k)|赞(0)|评价(0)|浏览(129)

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

KafkaConsumerProperties.isEnableDlq介绍

暂无

代码示例

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

@Override
protected MessageHandler getPolledConsumerErrorMessageHandler(ConsumerDestination destination, String group,
    ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  if (properties.getExtension().isEnableDlq()) {
    return getErrorMessageHandler(destination, group, properties);

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

@Override
protected MessageHandler getPolledConsumerErrorMessageHandler(ConsumerDestination destination, String group,
    ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  if (properties.getExtension().isEnableDlq()) {
    return getErrorMessageHandler(destination, group, properties);

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

private boolean isAutoCommitOnError(ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  return properties.getExtension().getAutoCommitOnError() != null
      ? properties.getExtension().getAutoCommitOnError()
      : properties.getExtension().isAutoCommitOffset() && properties.getExtension().isEnableDlq();
}

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

private boolean isAutoCommitOnError(ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  return properties.getExtension().getAutoCommitOnError() != null
      ? properties.getExtension().getAutoCommitOnError()
      : properties.getExtension().isAutoCommitOffset() && properties.getExtension().isEnableDlq();
}

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

private boolean isAutoCommitOnError(ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
  return properties.getExtension().getAutoCommitOnError() != null
      ? properties.getExtension().getAutoCommitOnError()
      : properties.getExtension().isAutoCommitOffset() && properties.getExtension().isEnableDlq();
}

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

Assert.isTrue(!properties.getExtension().isEnableDlq(),
      "enableDLQ is not allowed when listening to topic patterns");
  if (this.logger.isDebugEnabled()) {
Assert.isTrue(!anonymous || !properties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
if (properties.getInstanceCount() == 0) {

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

Assert.isTrue(!anonymous || !consumerProperties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
String consumerGroup = anonymous ? "anonymous." + UUID.randomUUID().toString() : group;
source.setRawMessageHeader(consumerProperties.getExtension().isEnableDlq());
String clientId = name;
if (consumerProperties.getExtension().getConfiguration().containsKey(ConsumerConfig.CLIENT_ID_CONFIG)) {

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

Assert.isTrue(!anonymous || !consumerProperties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
String consumerGroup = anonymous ? "anonymous." + UUID.randomUUID().toString() : group;
source.setRawMessageHeader(consumerProperties.getExtension().isEnableDlq());
String clientId = name;
if (consumerProperties.getExtension().getConfiguration().containsKey(ConsumerConfig.CLIENT_ID_CONFIG)) {

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

Assert.isTrue(!properties.getExtension().isEnableDlq(),
      "enableDLQ is not allowed when listening to topic patterns");
  if (this.logger.isDebugEnabled()) {
Assert.isTrue(!anonymous || !properties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
if (properties.getInstanceCount() == 0) {

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

static void prepareConsumerBinding(String name, String group, ApplicationContext context,
                    KafkaTopicProvisioner kafkaTopicProvisioner,
                    KafkaStreamsBinderConfigurationProperties binderConfigurationProperties,
                    ExtendedConsumerProperties<KafkaStreamsConsumerProperties> properties,
                    Map<String, KafkaStreamsDlqDispatch> kafkaStreamsDlqDispatchers) {
  ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties = new ExtendedConsumerProperties<>(
      properties.getExtension());
  if (binderConfigurationProperties.getSerdeError() == KafkaStreamsBinderConfigurationProperties.SerdeError.sendToDlq) {
    extendedConsumerProperties.getExtension().setEnableDlq(true);
  }
  String[] inputTopics = StringUtils.commaDelimitedListToStringArray(name);
  for (String inputTopic : inputTopics) {
    kafkaTopicProvisioner.provisionConsumerDestination(inputTopic, group, extendedConsumerProperties);
  }
  if (extendedConsumerProperties.getExtension().isEnableDlq()) {
    KafkaStreamsDlqDispatch kafkaStreamsDlqDispatch = !StringUtils.isEmpty(extendedConsumerProperties.getExtension().getDlqName()) ?
        new KafkaStreamsDlqDispatch(extendedConsumerProperties.getExtension().getDlqName(), binderConfigurationProperties,
            extendedConsumerProperties.getExtension()) : null;
    for (String inputTopic : inputTopics) {
      if (StringUtils.isEmpty(extendedConsumerProperties.getExtension().getDlqName())) {
        String dlqName = "error." + inputTopic + "." + group;
        kafkaStreamsDlqDispatch = new KafkaStreamsDlqDispatch(dlqName, binderConfigurationProperties,
            extendedConsumerProperties.getExtension());
      }
      SendToDlqAndContinue sendToDlqAndContinue = context.getBean(SendToDlqAndContinue.class);
      sendToDlqAndContinue.addKStreamDlqDispatch(inputTopic, kafkaStreamsDlqDispatch);
      kafkaStreamsDlqDispatchers.put(inputTopic, kafkaStreamsDlqDispatch);
    }
  }
}

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

final ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
KafkaConsumerProperties kafkaConsumerProperties = properties.getExtension();
if (kafkaConsumerProperties.isEnableDlq()) {
  KafkaProducerProperties dlqProducerProperties = kafkaConsumerProperties.getDlqProducerProperties();
  ProducerFactory<?, ?> producerFactory = this.transactionManager != null

代码示例来源：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

final ExtendedConsumerProperties<KafkaConsumerProperties> properties) {
KafkaConsumerProperties kafkaConsumerProperties = properties.getExtension();
if (kafkaConsumerProperties.isEnableDlq()) {
  KafkaProducerProperties dlqProducerProperties = kafkaConsumerProperties.getDlqProducerProperties();
  ProducerFactory<?, ?> producerFactory = this.transactionManager != null

代码示例来源：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

@Override
protected MessageHandler getErrorMessageHandler(final ConsumerDestination destination, final String group,
    final ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties) {
  if (extendedConsumerProperties.getExtension().isEnableDlq()) {
    ProducerFactory<byte[], byte[]> producerFactory = this.transactionManager != null
        ? this.transactionManager.getProducerFactory()

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

Assert.isTrue(!anonymous || !extendedConsumerProperties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
String consumerGroup = anonymous ? "anonymous." + UUID.randomUUID().toString() : group;

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

final ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties) {
boolean anonymous = !StringUtils.hasText(group);
Assert.isTrue(!anonymous || !extendedConsumerProperties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
String consumerGroup = anonymous ? "anonymous." + UUID.randomUUID().toString() : group;

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

final ExtendedConsumerProperties<KafkaConsumerProperties> extendedConsumerProperties) {
boolean anonymous = !StringUtils.hasText(group);
Assert.isTrue(!anonymous || !extendedConsumerProperties.getExtension().isEnableDlq(),
    "DLQ support is not available for anonymous subscriptions");
String consumerGroup = anonymous ? "anonymous." + UUID.randomUUID().toString() : group;

内容来源于网络，如有侵权，请联系作者删除！

KafkaConsumerProperties

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com