Agmen Topic Inspector for Kafka

A powerful, native Visual Studio Code extension for inspecting, searching, and managing Kafka topics directly within your IDE.

Features

• Multiple Connections: Add and manage multiple Kafka clusters (Dev, Test, Prod) securely via VS Code's Secret Storage.
• Advanced Authentication: Supports plaintext, SSL/TLS, and SASL authentication (PLAIN, SCRAM-SHA-256, SCRAM-SHA-512).
• Schema Registry Integration: Automatically decodes Protobuf, Avro, and JSON Schema messages using Confluent wire format when Schema Registry details are provided.
• Deep Search: Search through Kafka topics by JSON fields, precise offsets, or timestamps.
• Flexible Ordering: Support for scanning from oldest-first or newest-first.
• Watch Mode: Real-time tailing of new messages matching your search criteria.
• Message Replay: Resubmit messages back to topics (Pro feature).
• Data Export: Export search results to JSON or CSV formats (Pro feature).
• Dark/Light Theme Support: Native VS Code webview styling ensures it always matches your editor theme.

Installation

1. Open the Extensions view in VS Code (Ctrl+Shift+X or Cmd+Shift+X).
2. Search for "Agmen Topic Inspector for Kafka".
3. Click Install.

Usage

1. Click the Agmen Topic Inspector icon in the Activity Bar.
2. Click Add Connection to configure your Kafka brokers.
   • Enter your broker list (host:port).
   • Configure SSL/SASL if required.
   • Add Schema Registry details if you want automatic deserialization of binary formats.
3. Click Fetch Topics to load available topics.
4. Select one or more topics.
5. Use the Search pane to find messages:
   • Filter by specific JSON fields and expected values.
   • Choose how many recent messages to scan and how many results to return.
6. Click Search for historical messages, or Watch to tail new incoming messages.

Pro Version

The Free Tier supports basic topic inspection and searching (limited to 50 results). Unlock the Pro version for:

• Unlimited Search Results
• Unlimited Watch Mode
• Export to JSON/CSV
• Message Replay Functionality

To upgrade:

1. Open the Inspector.
2. Click the Upgrade to Pro icon in the toolbar.
3. Click Buy Pro to purchase a license, or I have a license key if you already bought one.

Requirements

• VS Code 1.93.0 or higher.
• A reachable Apache Kafka cluster (supports managed services like Aiven, Confluent Cloud, MSK, etc.).

Security

Your connection strings, passwords, and API keys are stored securely using the native VS Code SecretStorage API. They are never transmitted anywhere except directly to your designated Kafka clusters and Schema Registries. License verification communicates solely with the LemonSqueezy API.

Telemetry

This extension does not collect or transmit any telemetry or usage data.

Support

For issues, feature requests, or support, please open an issue in this repository or contact Agmen Software support.