org.springframework.kafka.test.utils.KafkaTestUtils.senderProps()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(88)

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

KafkaTestUtils.senderProps介绍

[英]Set up test properties for an producer.
[中]为生产者设置测试属性。

代码示例

代码示例来源:origin: spring-projects/spring-kafka

/**
 * Set up test properties for an {@code <Integer, String>} producer.
 * @param embeddedKafka a {@link org.springframework.kafka.test.rule.KafkaEmbedded} instance.
 * @return the properties.
 * @deprecated since 2.2 in favor of {@link #producerProps(EmbeddedKafkaBroker)}
 */
@SuppressWarnings("deprecation")
@Deprecated
public static Map<String, Object> producerProps(org.springframework.kafka.test.rule.KafkaEmbedded embeddedKafka) {
  return senderProps(embeddedKafka.getBrokersAsString());
}

代码示例来源:origin: spring-projects/spring-kafka

/**
 * Set up test properties for an {@code <Integer, String>} producer.
 * @param embeddedKafka a {@link EmbeddedKafkaBroker} instance.
 * @return the properties.
 */
public static Map<String, Object> producerProps(EmbeddedKafkaBroker embeddedKafka) {
  return senderProps(embeddedKafka.getBrokersAsString());
}

代码示例来源:origin: spring-projects/spring-kafka

@Bean
public Map<String, Object> producerConfigs() {
  return KafkaTestUtils.senderProps(this.brokerAddresses);
}

代码示例来源:origin: spring-projects/spring-kafka

@Bean
public Map<String, Object> producerConfigs() {
  return KafkaTestUtils.senderProps(this.brokerAddresses);
}

代码示例来源:origin: spring-projects/spring-kafka

@Bean
public Map<String, Object> producerConfigs() {
  Map<String, Object> senderProps = KafkaTestUtils.senderProps(this.brokerAddresses);
  senderProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
  senderProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
  return senderProps;
}

代码示例来源:origin: org.springframework.kafka/spring-kafka-test

/**
 * Set up test properties for an {@code <Integer, String>} producer.
 * @param embeddedKafka a {@link EmbeddedKafkaBroker} instance.
 * @return the properties.
 */
public static Map<String, Object> producerProps(EmbeddedKafkaBroker embeddedKafka) {
  return senderProps(embeddedKafka.getBrokersAsString());
}

代码示例来源:origin: org.springframework.kafka/spring-kafka-test

/**
 * Set up test properties for an {@code <Integer, String>} producer.
 * @param embeddedKafka a {@link org.springframework.kafka.test.rule.KafkaEmbedded} instance.
 * @return the properties.
 * @deprecated since 2.2 in favor of {@link #producerProps(EmbeddedKafkaBroker)}
 */
@SuppressWarnings("deprecation")
@Deprecated
public static Map<String, Object> producerProps(org.springframework.kafka.test.rule.KafkaEmbedded embeddedKafka) {
  return senderProps(embeddedKafka.getBrokersAsString());
}

相关文章