Interface ClientFactory<K,V>
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
ClientFactoryDefault
This is here to enable testing.
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.kafka.clients.admin.AdmincreateAdmin(Map<String, Object> adminProps) createConsumer(Map<String, Object> consumerProps)
-
Method Details
-
createConsumer
-
createAdmin
-