Topic Browse 0.6.0 Readme

Overview

Allows for browsing and searching for messages on a Kafka Cluster. Deserializes messages into their respective string format and allows for filtering on messages based on their string payload.

Browsing

Messages with payloads of the following types are supported:

  • STRING

  • AVRO

  • JSON_SCHEMA

  • PROTOBUF

JSON Schema and PROTOBUF are supported with Apicurio Schema Registry only.

Filtering

Message filtering based on the string representation of the deserialized payload. Only messages containing the (optional) provided request field query are returned.

Loggers

Below is a per-package breakdown of important packages to help operators configure logging:

Package Logger Description

io.axual.topicbrowse

Root package

Root Package

io.axual.topicbrowse.consumer

Consumer Service

Kafka consumer lifecycle, partition consumption coordination, and offset management

io.axual.topicbrowse.deserialize

Message Deserialization

Message and header conversion from byte arrays to string representations

io.axual.topicbrowse.deserialize.field.avro

Avro Deserializer

Avro message deserialization

io.axual.topicbrowse.deserialize.field.jsonschema

JSON Schema Deserializer

JSON Schema message deserialization

io.axual.topicbrowse.deserialize.field.masker

Field Masker

Sensitive data masking functionality for JSON payloads

io.axual.topicbrowse.deserialize.field.protobuf

Protobuf Deserializer

Protobuf message deserialization

io.axual.topicbrowse.kafka

Kafka Client Config

Kafka client configuration, authentication strategies (mTLS, SASL/PLAIN, SASL/SCRAM), and SSL setup

io.axual.topicbrowse.validation

Validation Service

Request validation, topic existence checking, and access verification