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

KafkaProducerProperties.<init>介绍

暂无

代码示例

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

@Override
  public KafkaProducerProperties getExtendedProducerProperties(String channelName) {
    if (this.bindings.containsKey(channelName) && this.bindings.get(channelName).getProducer() != null) {
      return this.bindings.get(channelName).getProducer();
    }
    else {
      return new KafkaProducerProperties();
    }
  }
}

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

@Override
@SuppressWarnings("unchecked")
protected Binding<KStream<Object, Object>> doBindProducer(String name, KStream<Object, Object> outboundBindTarget,
                            ExtendedProducerProperties<KafkaStreamsProducerProperties> properties) {
  ExtendedProducerProperties<KafkaProducerProperties> extendedProducerProperties = new ExtendedProducerProperties<>(
      new KafkaProducerProperties());
  this.kafkaTopicProvisioner.provisionProducerDestination(name, extendedProducerProperties);
  Serde<?> keySerde = this.keyValueSerdeResolver.getOuboundKeySerde(properties.getExtension());
  Serde<?> valueSerde = this.keyValueSerdeResolver.getOutboundValueSerde(properties, properties.getExtension());
  to(properties.isUseNativeEncoding(), name, outboundBindTarget, (Serde<Object>) keySerde, (Serde<Object>) valueSerde);
  return new DefaultBinding<>(name, null, outboundBindTarget, null);
}

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

ProducerFactory<byte[], byte[]> producerFactory = this.transactionManager != null
    ? this.transactionManager.getProducerFactory()
    : getProducerFactory(null, new ExtendedProducerProperties<>(new KafkaProducerProperties()));
final KafkaTemplate<byte[], byte[]> kafkaTemplate = new KafkaTemplate<>(producerFactory);
return new MessageHandler() {