接口 TConsumer<V>
-
- 所有超级接口:
AutoCloseable
- 所有已知实现类:
TaosConsumer
public interface TConsumer<V> extends AutoCloseable
-
-
方法概要
所有方法 实例方法 抽象方法 修饰符和类型 方法 说明 voidclose()voidcommitAsync()voidcommitAsync(OffsetCommitCallback callback)voidcommitSync()ConsumerRecords<V>poll(Duration timeout)voidsubscribe(Collection<String> topics)Set<String>subscription()voidunsubscribe()
-
-
-
方法详细资料
-
subscribe
void subscribe(Collection<String> topics) throws SQLException
- 抛出:
SQLException
-
unsubscribe
void unsubscribe() throws SQLException- 抛出:
SQLException
-
subscription
Set<String> subscription() throws SQLException
- 抛出:
SQLException
-
poll
ConsumerRecords<V> poll(Duration timeout) throws SQLException
- 抛出:
SQLException
-
commitAsync
void commitAsync()
-
commitAsync
void commitAsync(OffsetCommitCallback callback)
-
commitSync
void commitSync() throws SQLException- 抛出:
SQLException
-
close
void close() throws SQLException- 指定者:
close在接口中AutoCloseable- 抛出:
SQLException
-
-