Kafka operations workflows

Topic management

1. Select a cluster and inspect broker metadata.
2. Review topic partitions, replication, and configuration.
3. Create topics with explicit partitions, replication, and required settings.
4. Confirm downstream impact before expanding partitions or updating configuration.
5. Review naming, retention, and recovery options before deletion.

Browse and produce messages

• Locate messages by partition, offset mode, or timestamp.
• Use server-side keyword filters, live tail, and cross-partition find tasks.
• Decode Avro or JSON Schema wire formats.
• Download raw keys/values or export JSONL.
• Produce small JSONL, CSV, or text batches with per-record results.

Producing messages requires validation and confirmation. Limit batch sizes and validate formats against a dedicated test topic.

Consumer offsets

1. Review partition lag and current offsets.
2. Choose a reset strategy and partitions.
3. Run dry-run and inspect old and new offsets.
4. Stop or coordinate affected consumers.
5. Execute the reset and watch recovery.

Ecosystem management

Schema Registry supports subject/version browsing and schema registration. Kafka Connect supports connector creation, pause, resume, restart, and task restart. ACL pages support browse, create, and delete. Reconfirm the cluster and connection identity before every write.