接口的使用
com.actionsoft.sdk.local.api.cc.KafkaAPI

使用KafkaAPI的程序包

程序包	说明
com.actionsoft.sdk.local.api
com.actionsoft.sdk.local.api.cc

com.actionsoft.sdk.local.api中KafkaAPI的使用

返回KafkaAPI的com.actionsoft.sdk.local.api中的方法

限定符和类型	方法和说明
<K,V> KafkaAPI<K,V>	CCAPI.getKafkaAPI(java.lang.String profileId) 根据配置，获得一个Kafka API对象（连接分布式消息服务）
<K,V> KafkaAPI<K,V>	CCAPI.getKafkaAPI(java.lang.String profileId, <any> keySerializer, <any> valueSerializer) 获得kafka API对象，用于发送
<K,V> KafkaAPI<K,V>	CCAPI.getKafkaAPI(java.lang.String profileId, <any> keyDeserializer, <any> valueDeserializer) 获得kafka API对象，用于接收，Deserializer des = new DefDes(String.class); KafkaAPI api = getKafkaAPI(profileId,des, des);

com.actionsoft.sdk.local.api.cc中KafkaAPI的使用

返回KafkaAPI的com.actionsoft.sdk.local.api.cc中的方法

限定符和类型	方法和说明
KafkaAPI<K,V>	KafkaAPI.autoFlush(boolean autoFlush) 设置消息发送是否自动刷新
KafkaAPI<K,V>	KafkaAPI.topic(java.lang.String defaultTopic) 设置默认发送消息的topic