public class DefaultKafkaProducerFactory extends Object implements KafkaProducerFactory
Producer
instances.Constructor and Description |
---|
DefaultKafkaProducerFactory() |
Modifier and Type | Method and Description |
---|---|
<any> |
newKafkaProducer(Properties config)
Creates a new Kafka Producer from the given configuration properties.
|
public <any> newKafkaProducer(Properties config)
newKafkaProducer
in interface KafkaProducerFactory
config
- Kafka Producer configuration
properties.Producer
.Copyright © 1999-2017. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.