Kafka

Source: https://runstack.engineer/docs/toolkits/kafka

Produce to and administer Apache Kafka on Confluent Cloud: topics, consumer lag, ACLs, clusters, API keys, schemas, and compatibility.

Tools (68):

Tool	Description
`kafkaListClusters`	List Kafka clusters on the REST endpoint.
`kafkaGetCluster`	Get the Kafka cluster resource.
`kafkaListTopics`	List topics on the cluster.
`kafkaGetTopic`	Get one topic with partitions and configs.
`kafkaCreateTopic`	Create a topic with partitions and configs.
`kafkaIncreaseTopicPartitions`	Increase a topic partition count.
`kafkaDeleteTopic`	Delete a topic and all its data.
`kafkaListTopicConfigs`	List all config parameters of a topic.
`kafkaGetTopicConfig`	Get one topic config parameter.
`kafkaAlterTopicConfigs`	Set or delete topic configs in batch.
`kafkaUpdateTopicConfig`	Set a single topic config value.
`kafkaDeleteTopicConfig`	Reset a topic config to default.
`kafkaListPartitions`	List partitions of a topic.
`kafkaGetPartition`	Get one partition with leader and replicas.
`kafkaGetPartitionOffsets`	Get beginning/end offsets of a partition.
`kafkaProduceRecord`	Produce a single record to a topic.
`kafkaProduceRecordsBatch`	Produce a batch of records to a topic.
`kafkaListBrokers`	List brokers of the cluster.
`kafkaGetBroker`	Get one broker with host and rack.
`kafkaListBrokerConfigs`	List dynamic broker configs.
`kafkaGetBrokerConfig`	Get one dynamic broker config.
`kafkaAlterBrokerConfigs`	Set or delete broker configs in batch.
`kafkaListConsumerGroups`	List consumer groups.
`kafkaGetConsumerGroup`	Get one consumer group with state.
`kafkaListConsumers`	List active consumers of a group.
`kafkaGetConsumer`	Get one consumer member.
`kafkaGetConsumerLagSummary`	Get lag summary of a group.
`kafkaListConsumerLags`	List per-topic lags of a group.
`kafkaGetConsumerLag`	Get lag for one topic partition.
`kafkaListConsumerAssignments`	List partition assignments of a consumer.
`kafkaGetConsumerAssignment`	Get one partition assignment of a consumer.
`kafkaListAcls`	List ACLs with optional filters.
`kafkaCreateAcl`	Create one ACL entry.
`kafkaCreateAclsBatch`	Create multiple ACL entries.
`kafkaDeleteAcls`	Delete ACLs matching criteria.
`kafkaListEnvironments`	List Confluent Cloud environments.
`kafkaGetEnvironment`	Get one environment.
`kafkaCreateEnvironment`	Create a Confluent Cloud environment.
`kafkaUpdateEnvironment`	Rename an environment.
`kafkaDeleteEnvironment`	Delete an empty environment.
`kafkaListManagedClusters`	List managed Kafka clusters in an environment.
`kafkaGetManagedCluster`	Get a managed cluster with endpoints.
`kafkaCreateManagedCluster`	Provision a Kafka cluster.
`kafkaUpdateManagedCluster`	Rename, upgrade, or scale a cluster.
`kafkaDeleteManagedCluster`	Delete a managed cluster.
`kafkaListApiKeys`	List API keys (metadata only).
`kafkaGetApiKey`	Get one API key metadata.
`kafkaCreateApiKey`	Create an API key (secret shown once).
`kafkaUpdateApiKey`	Update an API key description.
`kafkaDeleteApiKey`	Delete (revoke) an API key.
`kafkaListServiceAccounts`	List service accounts.
`kafkaGetServiceAccount`	Get one service account.
`kafkaCreateServiceAccount`	Create a service account.
`kafkaUpdateServiceAccount`	Update a service account.
`kafkaDeleteServiceAccount`	Delete a service account.
`kafkaListSubjects`	List Schema Registry subjects.
`kafkaListSubjectVersions`	List versions under a subject.
`kafkaGetSchemaVersion`	Get one schema version.
`kafkaGetSchemaById`	Get a schema by global ID.
`kafkaRegisterSchema`	Register a schema version under a subject.
`kafkaLookupSchema`	Look up subject/version for a schema.
`kafkaDeleteSubject`	Soft-delete a subject.
`kafkaDeleteSchemaVersion`	Soft-delete one schema version.
`kafkaGetGlobalCompatibility`	Get global compatibility level.
`kafkaUpdateGlobalCompatibility`	Set global compatibility level.
`kafkaGetSubjectCompatibility`	Get subject compatibility level.
`kafkaUpdateSubjectCompatibility`	Set subject compatibility level.
`kafkaTestCompatibility`	Test a candidate schema for compatibility.