org.apache.beam.it.kafka

Classes

• KafkaResourceManager
• KafkaResourceManager.Builder

Exceptions

• KafkaResourceManagerException