org.trellisldp.kafka

Class KafkaPublisher

java.lang.Object

org.trellisldp.kafka.KafkaPublisher

All Implemented Interfaces:

EventService

public class KafkaPublisher
extends Object
implements EventService

A Kafka message producer capable of publishing messages to a Kafka cluster.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_KAFKA_TOPIC The configuration key controlling the name of the kafka topic.

Constructor Summary

Constructors

Constructor and Description
KafkaPublisher() Create a new Kafka Publisher.
KafkaPublisher(Producer<String,String> producer) Create a new Kafka Publisher.
KafkaPublisher(Producer<String,String> producer, String topic) Create a new Kafka Publisher.

Method Summary

Modifier and Type	Method and Description
void	emit(Event event) Emit an event to the event service.

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_KAFKA_TOPIC

public static final String CONFIG_KAFKA_TOPIC

The configuration key controlling the name of the kafka topic.

See Also:

Constant Field Values

Constructor Detail

KafkaPublisher

@Inject
public KafkaPublisher()

Create a new Kafka Publisher.

KafkaPublisher

public KafkaPublisher(Producer<String,String> producer)

Create a new Kafka Publisher.

Parameters:

producer - the producer

KafkaPublisher

public KafkaPublisher(Producer<String,String> producer,
                      String topic)

Create a new Kafka Publisher.

Parameters:

producer - the producer

topic - the name of the kafka topic

Method Detail

emit

public void emit(Event event)

Description copied from interface: EventService

Emit an event to the event service.

Specified by:

emit in interface EventService

Parameters:

event - the event