KosmoKrator

data

Confluent Cloud CLI for Cron Jobs

Use the Confluent Cloud CLI for cron jobs with headless JSON commands, schema discovery, credentials, and permission controls.

7 functions 6 read 1 write API token auth

Confluent Cloud CLI for Cron Jobs

Schedule repeatable integration workflows from cron while keeping credentials in KosmoKrator config.

Use the headless CLI from cron when an operation should run without an interactive agent session. The Confluent Cloud CLI uses the same integration registry as the TUI, Lua runtime, and MCP gateway, but returns predictable command output for automation.

Command Shape

# Confluent Cloud CLI for Cron Jobs
kosmokrator integrations:configure confluent --set api_token="$CONFLUENT_API_TOKEN" --enable --read allow --write ask --json
kosmo integrations:call confluent.confluent_list_topics '{"cluster_id":"example_cluster_id"}' --json

Discovery Before Execution

Agents and scripts can inspect Confluent Cloud docs and schemas before choosing a function.

kosmo integrations:docs confluent --json
kosmo integrations:docs confluent.confluent_list_topics --json
kosmo integrations:schema confluent.confluent_list_topics --json
kosmo integrations:search "Confluent Cloud" --json
kosmo integrations:list --json

Useful Confluent Cloud CLI Functions

FunctionTypeParametersDescription
confluent.confluent_list_topics Read cluster_id List Kafka topics in a Confluent cluster. Returns topic names, partition counts, replication factors, and status.
confluent.confluent_get_topic Read topic_name, cluster_id Get full details of a specific Kafka topic by name. Returns partition count, replication factor, and topic configuration.
confluent.confluent_create_topic Write topic_name, partitions_count, replication_factor, configs, cluster_id Create a new Kafka topic in a Confluent cluster. Specify the topic name, partition count, and optional replication factor and configs.
confluent.confluent_list_clusters Read none List Kafka clusters in your Confluent Cloud environment. Returns cluster IDs, names, types, and status.
confluent.confluent_get_cluster Read cluster_id Get details of a specific Kafka cluster. Returns broker count, controller info, and cluster configuration.
confluent.confluent_list_environments Read none List Confluent Cloud environments. Returns environment IDs, names, and associated cluster resources.
confluent.confluent_get_current_user Read none Get the currently authenticated Confluent Cloud user. Useful for verifying credentials and identifying the connected account.

Automation Notes

Related Confluent Cloud CLI Pages