properties = {
"consumer.bootstrap-server=${spring.embedded.kafka.brokers}",
"consumer.topic=" + TOPIC,
- "consumer.commit-interval=1s" })
+ "consumer.commit-interval=500ms" })
@EmbeddedKafka(topics = TOPIC, partitions = PARTITIONS)
@Slf4j
abstract class GenericApplicationTests<K, V>