org.cripac.isee.vpe.util.kafka

Class ByteArrayProducerFactory

java.lang.Object

org.cripac.isee.vpe.util.kafka.ByteArrayProducerFactory

All Implemented Interfaces:

Serializable, Factory<ByteArrayProducer>

public class ByteArrayProducerFactory
extends Object
implements Factory<ByteArrayProducer>

Object factory for producing Kafka producers with a fixed configuration.

Author:

Ken Yu, CRIPAC, 2016

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private Properties	config Configuration for constructing the object.
private static long	serialVersionUID

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
ByteArrayProducer	produce() Produce a new object.

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

config

private Properties config

Configuration for constructing the object.

Constructor Detail

ByteArrayProducerFactory

public ByteArrayProducerFactory(@Nonnull
                                Properties prop)

Input a property for constructing the Kafka producer.

Method Detail

produce

@Nonnull
public ByteArrayProducer produce()

Description copied from interface: Factory

Produce a new object.

Specified by:

produce in interface Factory<ByteArrayProducer>

Returns:

An object newly produced. Returns null on failure.