Package org.apache.beam.it.kafka

Package for managing Kafka resources within integration tests.

See: Description

Class Summary

Class	Description
KafkaResourceManager	Client for managing Kafka resources.
KafkaResourceManager.Builder	Builder for KafkaResourceManager.

Exception Summary

Exception	Description
KafkaResourceManagerException	Custom exception for KafkaResourceManager implementations.

Package org.apache.beam.it.kafka Description

Package for managing Kafka resources within integration tests.