org.cripac.isee.vpe.util.kafka

Class KafkaProducerFactory<K,V>

java.lang.Object

org.cripac.isee.vpe.util.kafka.KafkaProducerFactory<K,V>

All Implemented Interfaces:

java.io.Serializable, Factory<org.apache.kafka.clients.producer.KafkaProducer<K,V>>

public class KafkaProducerFactory<K,V>
extends java.lang.Object
implements Factory<org.apache.kafka.clients.producer.KafkaProducer<K,V>>

Object factory for producing Kafka producers with a fixed configuration.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KafkaProducerFactory(java.util.Properties prop) Input a property for constructing the Kafka producer.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.KafkaProducer<K,V>	produce() Produce a new object.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaProducerFactory

public KafkaProducerFactory(@Nonnull
                            java.util.Properties prop)

Input a property for constructing the Kafka producer.

Method Detail

produce

@Nonnull
public org.apache.kafka.clients.producer.KafkaProducer<K,V> produce()

Description copied from interface: Factory

Produce a new object.

Specified by:

produce in interface Factory<org.apache.kafka.clients.producer.KafkaProducer<K,V>>

Returns:

An object newly produced. Returns null on failure.