Package org.mockserver.async.subscribe

Class KafkaMessageSubscriber

java.lang.Object

org.mockserver.async.subscribe.KafkaMessageSubscriber

All Implemented Interfaces:

MessageSubscriber

public class KafkaMessageSubscriber
extends Object
implements MessageSubscriber

A MessageSubscriber that uses a Kafka KafkaConsumer to subscribe to topics and record received messages. Runs a background poll loop on a daemon thread.

All KafkaConsumer access is confined to the single poll thread to avoid ConcurrentModificationException. Subscribe and unsubscribe requests are queued and drained at the top of each poll iteration.

Recorded messages are stored in a bounded BoundedMessageStore per channel to prevent unbounded memory growth.

Constructor Summary

Constructors

Constructor	Description
KafkaMessageSubscriber(String bootstrapServers, String groupId)	Create a subscriber connected to the given Kafka bootstrap servers using plaintext (no security).
KafkaMessageSubscriber(String bootstrapServers, String groupId, int maxRecordedMessages)	Create a subscriber with a custom recorded-message cap per channel.
KafkaMessageSubscriber(String bootstrapServers, String groupId, int maxRecordedMessages, KafkaSecurity security)	Create a subscriber with optional security configuration.

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).
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

KafkaMessageSubscriber

public KafkaMessageSubscriber(String bootstrapServers,
 String groupId)

Create a subscriber connected to the given Kafka bootstrap servers using plaintext (no security). Backward-compatible entry point.

Parameters:

bootstrapServers - comma-separated list of host:port pairs

groupId - the consumer group ID

KafkaMessageSubscriber

public KafkaMessageSubscriber(String bootstrapServers,
 String groupId,
 int maxRecordedMessages)

Create a subscriber with a custom recorded-message cap per channel.

KafkaMessageSubscriber

public KafkaMessageSubscriber(String bootstrapServers,
 String groupId,
 int maxRecordedMessages,
 KafkaSecurity security)

Create a subscriber with optional security configuration.

Parameters:

bootstrapServers - comma-separated list of host:port pairs

groupId - the consumer group ID

maxRecordedMessages - maximum recorded messages per channel

security - security configuration (may be null for plaintext)

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