public class KafkaSender extends Object
Constructor and Description |
---|
KafkaSender(KafkaConfig config) |
public KafkaSender(KafkaConfig config)
public void send(Collection<String> topics, String message) throws InterruptedException, ExecutionException
Copyright © 2016 The Open Web Application Security Project (OWASP). All rights reserved.