public interface KafkaStubMessagesInitializer
KafkaStubMessages
. This interface might have a
different implementation for the producer side and for the consumer side. That's
because you can't poll for a single message by different consumers.Modifier and Type | Method and Description |
---|---|
Map<String,org.apache.kafka.clients.consumer.Consumer> |
initialize(org.springframework.kafka.test.EmbeddedKafkaBroker broker,
org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties) |
Map<String,org.apache.kafka.clients.consumer.Consumer> initialize(org.springframework.kafka.test.EmbeddedKafkaBroker broker, org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties)
broker
- - embedded Kafka brokerkafkaProperties
- - kafka propertiesCopyright © 2016–2022 Spring. All rights reserved.