public class KafkaProperty extends Object
| 构造器和说明 |
|---|
KafkaProperty() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
addProducerConfigValue(String key,
Object value) |
boolean |
checkPrerequisites() |
String |
getDefaultTopic() |
Integer |
getPartition() |
Map<String,Object> |
getProducerConfig() |
void |
setDefaultTopic(String defaultTopic) |
void |
setPartition(Integer partition) |
void |
setProducerConfig(Map<String,Object> producerConfig) |
Copyright © 2021 hellothomas. All rights reserved.