KafkaProperty (jedi-core 0.0.13 API)

public class KafkaProperty
extends Object

构造器
构造器和说明
`KafkaProperty()`

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`addProducerConfigValue(String key, Object value)`
`void`	`addTopic(MessageType messageType, String topic)`
`boolean`	`checkPrerequisites()`
`String`	`getDefaultTopic()`
`Integer`	`getPartition()`
`Map<String,Object>`	`getProducerConfig()`
`Map<MessageType,String>`	`getTopics()`
`void`	`setDefaultTopic(String defaultTopic)`
`void`	`setPartition(Integer partition)`
`void`	`setProducerConfig(Map<String,Object> producerConfig)`

public void setDefaultTopic(String defaultTopic)

public void setPartition(Integer partition)

public void addProducerConfigValue(String key,
                                   Object value)

public Map<String,Object> getProducerConfig()

public void setProducerConfig(Map<String,Object> producerConfig)

public Map<MessageType,String> getTopics()

public void addTopic(MessageType messageType,
                     String topic)

类 KafkaProperty