| Package | Description |
|---|---|
| com.ailbb.act.entity | |
| com.ailbb.act.kafka |
| Modifier and Type | Method and Description |
|---|---|
$KafkaConnConfiguration |
$KafkaConnConfiguration.setAcks(int acks) |
$KafkaConnConfiguration |
$KafkaConnConfiguration.setBrokers(String brokers) |
$KafkaConnConfiguration |
$KafkaConnConfiguration.setPort(int port) |
$KafkaConnConfiguration |
$KafkaConnConfiguration.setSerializerKey(String serializerKey) |
$KafkaConnConfiguration |
$KafkaConnConfiguration.setSerializerValue(String serializerValue) |
| Modifier and Type | Method and Description |
|---|---|
$Kafka |
$Kafka.init($KafkaConnConfiguration kafkaConnConfiguration) |
Copyright © 2021. All rights reserved.