本文整理了Java中org.springframework.kafka.test.utils.KafkaTestUtils.senderProps()
方法的一些代码示例,展示了KafkaTestUtils.senderProps()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。KafkaTestUtils.senderProps()
方法的具体详情如下:
包路径:org.springframework.kafka.test.utils.KafkaTestUtils
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!