TsgcWSPClient_Kafka › Methods

TsgcWSPClient_Kafka Methods

Public methods, grouped by purpose.

Producer

Name	Description
Produce	Publishes a string record to a topic.
ProduceBytes	Publishes a binary (TBytes) record to a topic.
ProduceMessages	Publishes a batch of records to a partition.

Consumer

Name	Description
Subscribe	Subscribes to one or more topics.
Unsubscribe	Leaves the group and stops consuming the subscribed topics.
Poll	Fetches available records, waiting up to a timeout.
FetchMessages	Reads records from a topic/partition starting at an offset, without a consumer group.
CommitSync	Synchronously commits the current consumed offsets for the consumer group.
CommitOffset	Commits a specific offset for a topic/partition in the consumer group.

Offsets

Name	Description
GetEarliestOffset	Returns the earliest available offset for a topic/partition.
GetLatestOffset	Returns the latest available offset for a topic/partition.
GetCommittedOffset	Returns the committed offset for a topic/partition in the consumer group.

Admin

Name	Description
CreateTopic	Creates a new topic on the broker.
DeleteTopic	Deletes an existing topic from the broker.
GetMetadata	Retrieves cluster, topic and partition metadata.
ListGroups	Lists the consumer groups known to the broker.
DescribeGroups	Describes the members and state of one or more consumer groups.
GetApiVersions	Retrieves the API versions supported by the broker.