public class $KafkaConnConfiguration
extends com.ailbb.ajj.entity.$ConnConfiguration
| Constructor and Description |
|---|
$KafkaConnConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
int |
getAcks() |
int |
getPort() |
String |
getSerializerKey() |
String |
getSerializerValue() |
$KafkaConnConfiguration |
setAcks(int acks) |
$KafkaConnConfiguration |
setPort(int port) |
$KafkaConnConfiguration |
setSerializerKey(String serializerKey) |
$KafkaConnConfiguration |
setSerializerValue(String serializerValue) |
public int getPort()
getPort in class com.ailbb.ajj.entity.$ConnConfigurationpublic $KafkaConnConfiguration setPort(int port)
setPort in class com.ailbb.ajj.entity.$ConnConfigurationpublic int getAcks()
public $KafkaConnConfiguration setAcks(int acks)
public String getSerializerKey()
public $KafkaConnConfiguration setSerializerKey(String serializerKey)
public String getSerializerValue()
public $KafkaConnConfiguration setSerializerValue(String serializerValue)
Copyright © 2018. All rights reserved.