public class KafkaConfig
extends java.lang.Object
构造器和说明 |
---|
KafkaConfig(CloudProps cloudProps) |
限定符和类型 | 方法和说明 |
---|---|
java.util.Properties |
getConsumerProperties() |
java.lang.String |
getEventChannel() |
java.lang.String |
getEventGroup() |
java.util.Properties |
getProducerProperties() |
long |
getPublishTimeout() |
public KafkaConfig(CloudProps cloudProps)
public long getPublishTimeout()
public java.lang.String getEventChannel()
public java.lang.String getEventGroup()
public java.util.Properties getProducerProperties()
public java.util.Properties getConsumerProperties()