com.ailbb.act.kafka

Class $Kafka

java.lang.Object

com.ailbb.act.hadoop.$Hadoop

com.ailbb.act.kafka.$Kafka

public class $Kafka
extends $Hadoop

Constructor Summary

Constructors

Constructor and Description
$Kafka()

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.Producer	getProducer()
$Kafka	init($KafkaConnConfiguration kafkaConnConfiguration)
com.ailbb.ajj.entity.$Result	send(String topic, String value)
$Kafka	setProducer(org.apache.kafka.clients.producer.Producer producer)

Methods inherited from class com.ailbb.act.hadoop.$Hadoop

getKerberos, run, setKerberos

Methods inherited from class java.lang.Object

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

Constructor Detail

$Kafka

public $Kafka()

Method Detail

init

public $Kafka init($KafkaConnConfiguration kafkaConnConfiguration)

send

public com.ailbb.ajj.entity.$Result send(String topic,
                                         String value)
                                  throws Exception

Throws:

Exception

getProducer

public org.apache.kafka.clients.producer.Producer getProducer()

setProducer

public $Kafka setProducer(org.apache.kafka.clients.producer.Producer producer)