Package org.mockserver.async.subscribe

Class KafkaAvroMessageSubscriber

java.lang.Object

org.mockserver.async.subscribe.KafkaAvroMessageSubscriber

All Implemented Interfaces:

MessageSubscriber

public class KafkaAvroMessageSubscriber
extends Object
implements MessageSubscriber

A MessageSubscriber that consumes Confluent wire-format Avro messages from Kafka and records them as JSON — the consume/verify counterpart of KafkaAvroMessagePublisher.

For each consumed record the wire-format header (ConfluentWireFormat) is stripped to recover the schema id and Avro binary, the schema is resolved (from the SchemaRegistryClient by id, or the configured inline schema in registry-less mode), and the Avro binary is decoded back to JSON (AvroPayloadCodec). The recorded payload is therefore JSON, so the existing substring / JSON-path verification works unchanged.

Mirrors KafkaMessageSubscriber's poll-thread confinement: all KafkaConsumer access happens on the single background poll thread.

Constructor Summary

Constructors

Constructor	Description
KafkaAvroMessageSubscriber(String bootstrapServers, String groupId, int maxRecordedMessages, KafkaSecurity security, SchemaRegistryClient registryClient, String inlineSchemaJson)

Method Summary

Modifier and Type	Method	Description
void	close()	Clear all recorded messages and stop all subscriptions.
List<RecordedMessage>	getAllRecordedMessages()	Return all messages recorded across all channels.
List<RecordedMessage>	getRecordedMessages(String channel)	Return all messages recorded on the given channel since subscription started (or since the last reset).
boolean	isHealthy()
void	subscribe(String channel)	Start subscribing to the given channel.
void	unsubscribe(String channel)	Stop subscribing to the given channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaAvroMessageSubscriber

public KafkaAvroMessageSubscriber(String bootstrapServers,
 String groupId,
 int maxRecordedMessages,
 KafkaSecurity security,
 SchemaRegistryClient registryClient,
 String inlineSchemaJson)

Parameters:

bootstrapServers - comma-separated host:port pairs

groupId - the consumer group id

maxRecordedMessages - max recorded messages per channel

security - Kafka security (may be null)

registryClient - Schema Registry client, or null for registry-less mode

inlineSchemaJson - inline Avro schema for registry-less decoding (may be null when a registry is used)

Method Details

subscribe

public void subscribe(String channel)

Description copied from interface: MessageSubscriber

Start subscribing to the given channel. Messages will be recorded internally and are retrievable via MessageSubscriber.getRecordedMessages(String).

Specified by:

subscribe in interface MessageSubscriber

Parameters:

channel - the channel/topic to subscribe to

unsubscribe

public void unsubscribe(String channel)

Description copied from interface: MessageSubscriber

Stop subscribing to the given channel.

Specified by:

unsubscribe in interface MessageSubscriber

getRecordedMessages

public List<RecordedMessage> getRecordedMessages(String channel)

Description copied from interface: MessageSubscriber

Return all messages recorded on the given channel since subscription started (or since the last reset).

Specified by:

getRecordedMessages in interface MessageSubscriber

getAllRecordedMessages

public List<RecordedMessage> getAllRecordedMessages()

Description copied from interface: MessageSubscriber

Return all messages recorded across all channels.

Specified by:

getAllRecordedMessages in interface MessageSubscriber

close

public void close()

Description copied from interface: MessageSubscriber

Clear all recorded messages and stop all subscriptions.

Specified by:

close in interface MessageSubscriber

isHealthy

public boolean isHealthy()