Returns information about the Kafka cluster (brokers, controller).

Returns a list of brokers with their details.

Returns a list of all topic names in the cluster.

Returns detailed information about a specific topic.

Creates a new topic.

Deletes a topic.

Increases the number of partitions for a topic. Note: Partition count can only be increased, not decreased.

Get dynamic configs for a resource. resource_type: "topic", "broker", or "group" (case insensitive)

Update dynamic configs for a resource. resource_type: "topic", "broker", or "group" configs: Dictionary of config key-value pairs

Consumes messages from a topic. offset_spec: 'earliest', 'latest', or specific integer offset. timeout: seconds to wait for messages.

Lists all consumer groups.

Describes a specific consumer group.

Get the committed offsets and lag for a specific consumer group and topic. Returns the committed offset, high/low watermarks, and calculated lag for each partition.

Resets the offset of a consumer group using AdminClient. offset_spec: 'earliest', 'latest', or a specific integer offset string. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if the group is active or STABLE.

Rewinds consumer group offsets manually based on a specific timestamp. Finds offsets matching the timestamp using Consumer, then sets using AdminClient. dry_run: If True, only calculates and returns the proposed offset changes without applying them. force: If True, forces the modification even if the group is active or STABLE.

Produces a message to a topic.