K
- V
- public interface KafkaAPI<K,V>
extends java.io.Closeable
支持日志和审计的操作:send、poll
发送消息默认使用org.apache.kafka.common.serialization.Serdes根据发送消息K/V类型long/int/double/String/ByteBuffer/byte[]进行序列化;
接收消息必须指定序列化实现类,可使用内置DefDes构造long/int/double/String/ByteBuffer/byte[]类型的反序列化:
Deserializer<String> des = new DefDes<String>(String.class); KafkaAPI<String, String> api = SDK.getCCAPI().getKafkaAPI(profileId , des , des); api.topic("topic").send("test");
org.apache.kafka.common.serialization.Serdes
限定符和类型 | 接口和说明 |
---|---|
static interface |
KafkaAPI.ConsumerCallback<K,V>
消息接收的回调接口
|
static interface |
KafkaAPI.ProducerCallback<K,V>
消息发送的回调接口
|
限定符和类型 | 方法和说明 |
---|---|
KafkaAPI<K,V> |
autoFlush(boolean autoFlush)
设置消息发送是否自动刷新
|
void |
close()
关闭资源
|
void |
execute(KafkaAPI.ConsumerCallback<K,V> callback)
消息接收
|
void |
execute(KafkaAPI.ProducerCallback<K,V> callback)
消息发送
|
void |
flush()
刷新缓冲的消息
|
java.util.Map<MetricName,? extends Metric> |
metrics()
获得指标列表
@see
org.apache.kafka.clients.producer.Producer#metrics() |
java.util.List<PartitionInfo> |
partitionsFor(java.lang.String topic)
获得topic分区列表
|
<any> |
send(java.lang.Integer partition,
K key,
V data)
发送消息到默认topic
|
<any> |
send(java.lang.Integer partition,
java.lang.Long timestamp,
K key,
V data)
发送消息到默认topic
|
<any> |
send(K key,
V data)
发送消息到默认topic
|
<any> |
send(V data)
发送消息到默认topic
|
<any> |
sendTopic(java.lang.String topic,
java.lang.Integer partition,
K key,
V data)
发送消息到指定topic
|
<any> |
sendTopic(java.lang.String topic,
java.lang.Integer partition,
java.lang.Long timestamp,
K key,
V data)
发送消息到指定topic
|
<any> |
sendTopic(java.lang.String topic,
K key,
V data)
发送消息到指定topic
|
<any> |
sendTopic(java.lang.String topic,
V data)
发送消息到指定topic
|
KafkaAPI<K,V> |
topic(java.lang.String defaultTopic)
设置默认发送消息的topic
|
void close()
close
在接口中 java.lang.AutoCloseable
close
在接口中 java.io.Closeable
<any> send(V data)
<any> sendTopic(java.lang.String topic, V data)
<any> sendTopic(java.lang.String topic, java.lang.Integer partition, K key, V data)
<any> sendTopic(java.lang.String topic, java.lang.Integer partition, java.lang.Long timestamp, K key, V data)
java.util.List<PartitionInfo> partitionsFor(java.lang.String topic)
java.util.Map<MetricName,? extends Metric> metrics()
org.apache.kafka.clients.producer.Producer#metrics()
void execute(KafkaAPI.ProducerCallback<K,V> callback)
void flush()
void execute(KafkaAPI.ConsumerCallback<K,V> callback)
Copyright © Actionsoft Co., Ltd. All Rights Reserved.