public interface KafkaConnectionPool
Modifier and Type | Method and Description |
---|---|
void |
shutdown()
Shuts down Kafka connection pool.
|
void |
startUp()
Starts up Kafka connection pool.
|
void |
submitKafkaRequest(KafkaRequest request)
Submits KafkaRequest to be scheduled.
|
void startUp()
void shutdown()
void submitKafkaRequest(KafkaRequest request)
request
- request to be scheduled.