kafka
kafka copied to clipboard
KAFKA-14101: Improve documentation for consuming from embedded Kafka cluster topics in Connect integration testing framework
Depends on https://github.com/apache/kafka/pull/12429, which should implement a logical fix for KAFKA-14101. This follow-up PR is intended to help harden our integration tests against the mistakes that caused KAFKA-14101 by:
- Renaming
EmbeddedKafkaCluster::consumetoEmbeddedKafkaCluster::consumeAtLeastin order to clarify behavior and help distinguish between it andEmbeddedKafkaCluster::consumeAll. - Adding a note to the Javadocs for
EmbeddedKafkaCluster::consumeAtLeastwarning about out-of-order consumption and data missing from topic partitions.
Though ready for review now, this PR should not be merged until https://github.com/apache/kafka/pull/12429 is merged.