org.owasp.appsensor.kafka.util

Class KafkaSender

java.lang.Object

org.owasp.appsensor.kafka.util.KafkaSender

public class KafkaSender
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSender(KafkaConfig config)

Method Summary

Modifier and Type	Method and Description
void	send(Collection<String> topics, String message)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSender

public KafkaSender(KafkaConfig config)

Method Detail

send

public void send(Collection<String> topics,
                 String message)
          throws InterruptedException,
                 ExecutionException