com.taosdata.jdbc.ws.tmq.entity

类 TMQRequestFactory

java.lang.Object

com.taosdata.jdbc.ws.tmq.entity.TMQRequestFactory

public class TMQRequestFactory
extends Object

generate id for request

构造器概要

构造器

构造器和说明
TMQRequestFactory()

方法概要

限定符和类型	方法和说明
Request	generateAssignment(String topic)
Request	generateCommit(long messageId)
Request	generateCommitOffset(TopicPartition topicPartition, long offset)
Request	generateCommitted(TopicPartition[] topicPartitions)
Request	generateFetch(long messageId)
Request	generateFetchBlock(long fetchRequestId, long messageId)
Request	generatePoll(long blockingTime)
Request	generatePosition(TopicPartition[] topicPartitions)
Request	generateSeek(String topic, int vgId, long offset)
Request	generateSubscribe(String user, String password, String db, String groupId, String clientId, String offsetRest, String[] topics, String enableAutoCommit, String autoCommitIntervalMs, String snapshotEnable, String withTableName)
Request	generateSubscription()
Request	generateUnsubscribe()
long	getId(String action)

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

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

构造器详细资料

TMQRequestFactory

public TMQRequestFactory()

方法详细资料

getId

public long getId(String action)

generateSubscribe

public Request generateSubscribe(String user,
                                 String password,
                                 String db,
                                 String groupId,
                                 String clientId,
                                 String offsetRest,
                                 String[] topics,
                                 String enableAutoCommit,
                                 String autoCommitIntervalMs,
                                 String snapshotEnable,
                                 String withTableName)

generatePoll

public Request generatePoll(long blockingTime)

generateFetch

public Request generateFetch(long messageId)

generateFetchBlock

public Request generateFetchBlock(long fetchRequestId,
                                  long messageId)

generateCommit

public Request generateCommit(long messageId)

generateSeek

public Request generateSeek(String topic,
                            int vgId,
                            long offset)

generateAssignment

public Request generateAssignment(String topic)

generateUnsubscribe

public Request generateUnsubscribe()

generateCommitted

public Request generateCommitted(TopicPartition[] topicPartitions)

generatePosition

public Request generatePosition(TopicPartition[] topicPartitions)

generateSubscription

public Request generateSubscription()

generateCommitOffset

public Request generateCommitOffset(TopicPartition topicPartition,
                                    long offset)