com.taosdata.jdbc.tmq

类 TaosConsumer<V>

java.lang.Object

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

所有已实现的接口:

AutoCloseable

public class TaosConsumer<V>
extends Object
implements AutoCloseable

构造器概要

构造器

构造器和说明
TaosConsumer(Properties properties) Note: after creating a TaosConsumer you must always close() it to avoid resource leaks.

方法概要

限定符和类型	方法和说明
Map<TopicPartition,Long>	beginningOffsets(String topic)
void	close()
void	commitAsync()
void	commitAsync(OffsetCommitCallback<V> callback)
void	commitCallbackHandler(int code) 已过时。
void	commitSync()
Map<TopicPartition,Long>	endOffsets(String topic)
ConsumerRecords<V>	poll(Duration timeout)
Map<TopicPartition,Long>	position(String topic)
long	position(TopicPartition tp)
void	seek(TopicPartition partition, long offset)
void	subscribe(Collection<String> topics)
Set<String>	subscription()
void	unsubscribe()

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

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

构造器详细资料

TaosConsumer

public TaosConsumer(Properties properties)
             throws SQLException

Note: after creating a TaosConsumer you must always close() it to avoid resource leaks.

抛出:

SQLException

方法详细资料

subscribe

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

抛出:

SQLException

unsubscribe

public void unsubscribe()
                 throws SQLException

抛出:

SQLException

subscription

public Set<String> subscription()
                         throws SQLException

抛出:

SQLException

poll

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

抛出:

SQLException

commitCallbackHandler

@Deprecated
public void commitCallbackHandler(int code)

已过时。

jni consumer will call back whit error code when commit async

参数:

code - error code

commitAsync

public void commitAsync()

commitAsync

public void commitAsync(OffsetCommitCallback<V> callback)

commitSync

public void commitSync()
                throws SQLException

抛出:

SQLException

seek

public void seek(TopicPartition partition,
                 long offset)
          throws SQLException

抛出:

SQLException

position

public long position(TopicPartition tp)
              throws SQLException

抛出:

SQLException

position

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

抛出:

SQLException

beginningOffsets

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

抛出:

SQLException

endOffsets

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

抛出:

SQLException

close

public void close()
           throws SQLException

指定者:

close 在接口中 AutoCloseable

抛出:

SQLException