com.ailbb.act.kafka

Class $Kafka

java.lang.Object

com.ailbb.act.kafka.$Kafka

public class $Kafka
extends Object

Created by Wz on 8/28/2018.

Field Summary

Fields

Modifier and Type	Field and Description
static int	$PORT

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 java.lang.Object

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

Field Detail

$PORT

public static final int $PORT

See Also:

Constant Field Values

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)

getProducer

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

setProducer

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