producer:
image: juplo/spring-producer:1.0-SNAPSHOT
environment:
- juplo.bootstrap-server: kafka:9092
- juplo.client-id: producer
+ spring.kafka.bootstrap-servers: kafka:9092
+ spring.kafka.client-id: producer
juplo.producer.topic: test
consumer:
properties = {
"spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
"spring.kafka.consumer.auto-offset-reset=earliest",
- "juplo.bootstrap-server=${spring.embedded.kafka.brokers}",
"juplo.producer.topic=" + TOPIC})
@AutoConfigureMockMvc
@EmbeddedKafka(topics = TOPIC, partitions = PARTITIONS)