com.taosdata.jdbc.tmq

类 JNIConsumer<V>

java.lang.Object

com.taosdata.jdbc.tmq.JNIConsumer<V>

所有已实现的接口:

Consumer<V>

public class JNIConsumer<V>
extends Object
implements Consumer<V>

构造器概要

构造器

构造器和说明
JNIConsumer()

方法概要

限定符和类型	方法和说明
Map<TopicPartition,Long>	beginningOffsets(String topic)
void	close() close consumer
void	closeOffset(long prt)
void	commitAsync(OffsetCommitCallback<V> callback)
void	commitSync() commit offset with sync
void	create(Properties properties) create consumer
Map<TopicPartition,Long>	endOffsets(String topic)
String	getErrMsg(int code)
ConsumerRecords<V>	poll(Duration timeout, Deserializer<V> deserializer) get result records
Map<TopicPartition,Long>	position(String topic)
long	position(TopicPartition partition)
void	releaseResultSet(long ptr)
void	seek(TopicPartition partition, long offset) If this API is invoked for the same partition more than once, the latest offset will be used on the next poll().
void	subscribe(Collection<String> topics) subscribe topics
Set<String>	subscription() get subscribe topics
void	unsubscribe() unsubscribe topics

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

JNIConsumer

public JNIConsumer()

方法详细资料

create

public void create(Properties properties)
            throws SQLException

从接口复制的说明: Consumer

create consumer

指定者:

create 在接口中 Consumer<V>

参数:

properties - ip / port / user / password and so on.

抛出:

SQLException - jni exception

subscribe

public void subscribe(Collection<String> topics)
               throws SQLException

从接口复制的说明: Consumer

subscribe topics

指定者:

subscribe 在接口中 Consumer<V>

参数:

topics - collection of topics

抛出:

SQLException - jni exception

unsubscribe

public void unsubscribe()
                 throws SQLException

从接口复制的说明: Consumer

unsubscribe topics

指定者:

unsubscribe 在接口中 Consumer<V>

抛出:

SQLException - jni exception

subscription

public Set<String> subscription()
                         throws SQLException

从接口复制的说明: Consumer

get subscribe topics

指定者:

subscription 在接口中 Consumer<V>

返回:

topic set

抛出:

SQLException - jni exception

poll

public ConsumerRecords<V> poll(Duration timeout,
                               Deserializer<V> deserializer)
                        throws SQLException

从接口复制的说明: Consumer

get result records

指定者:

poll 在接口中 Consumer<V>

参数:

timeout - wait time for poll data

deserializer - convert resultSet to javaBean

返回:

ConsumerRecord is the collection of javaBean

抛出:

SQLException - java reflect exception or resultSet convert exception

commitAsync

public void commitAsync(OffsetCommitCallback<V> callback)

指定者:

commitAsync 在接口中 Consumer<V>

seek

public void seek(TopicPartition partition,
                 long offset)

从接口复制的说明: Consumer

If this API is invoked for the same partition more than once, the latest offset will be used on the next poll().

指定者:

seek 在接口中 Consumer<V>

position

public long position(TopicPartition partition)

指定者:

position 在接口中 Consumer<V>

position

public Map<TopicPartition,Long> position(String topic)

指定者:

position 在接口中 Consumer<V>

beginningOffsets

public Map<TopicPartition,Long> beginningOffsets(String topic)

指定者:

beginningOffsets 在接口中 Consumer<V>

endOffsets

public Map<TopicPartition,Long> endOffsets(String topic)

指定者:

endOffsets 在接口中 Consumer<V>

commitSync

public void commitSync()
                throws SQLException

从接口复制的说明: Consumer

commit offset with sync

指定者:

commitSync 在接口中 Consumer<V>

抛出:

SQLException - jni exception

close

public void close()
           throws SQLException

从接口复制的说明: Consumer

close consumer

指定者:

close 在接口中 Consumer<V>

抛出:

SQLException - jni exception

releaseResultSet

public void releaseResultSet(long ptr)
                      throws SQLException

抛出:

SQLException

getErrMsg

public String getErrMsg(int code)

closeOffset

public void closeOffset(long prt)