程序包 com.taosdata.jdbc.tmq

类 TaosConsumer<V>

java.lang.Object

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

所有已实现的接口:

TConsumer<V>, AutoCloseable

public class TaosConsumer<V>
extends Object
implements TConsumer<V>

构造器概要

构造器

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

方法概要

修饰符和类型	方法	说明
void	close()
void	commitAsync()
void	commitAsync(OffsetCommitCallback callback)
void	commitCallbackHandler(int code)
void	commitSync()
ConsumerRecords<V>	poll(Duration timeout)
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

方法详细资料

commitCallbackHandler

public void commitCallbackHandler(int code)

subscribe

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

指定者:

subscribe 在接口中 TConsumer<V>

抛出:

SQLException

unsubscribe

public void unsubscribe()
                 throws SQLException

指定者:

unsubscribe 在接口中 TConsumer<V>

抛出:

SQLException

subscription

public Set<String> subscription()
                         throws SQLException

指定者:

subscription 在接口中 TConsumer<V>

抛出:

SQLException

poll

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

指定者:

poll 在接口中 TConsumer<V>

抛出:

SQLException

commitAsync

public void commitAsync()

指定者:

commitAsync 在接口中 TConsumer<V>

commitAsync

public void commitAsync(OffsetCommitCallback callback)

指定者:

commitAsync 在接口中 TConsumer<V>

commitSync

public void commitSync()
                throws SQLException

指定者:

commitSync 在接口中 TConsumer<V>

抛出:

SQLException

close

public void close()
           throws SQLException

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 TConsumer<V>

抛出:

SQLException