Uses of Class
org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput.Topic

Packages that use AbstractKafkaOutput.Topic

Package	Description
org.thales.punch.libraries.storm.bolt	Punchplatform bolts package.

Uses of AbstractKafkaOutput.Topic in org.thales.punch.libraries.storm.bolt

Methods in org.thales.punch.libraries.storm.bolt that return AbstractKafkaOutput.Topic

Modifier and Type	Method and Description
protected AbstractKafkaOutput.Topic	AbstractKafkaOutput.getTargetTopic(String streamId)

Methods in org.thales.punch.libraries.storm.bolt with parameters of type AbstractKafkaOutput.Topic

Modifier and Type	Method and Description
void	AbstractKafkaOutput.sendKafkaMessage(org.apache.storm.tuple.Tuple tuple, AbstractKafkaOutput.Topic topic, byte[] kafkaMessage) Call the Kafka producer to send the message