Package ai.superstream.core

Class MetadataConsumer

java.lang.Object

ai.superstream.core.MetadataConsumer

public class MetadataConsumer
extends Object

Consumes messages from the superstream.metadata_v1 topic.

Constructor Summary

Constructors

Constructor	Description
MetadataConsumer()

Method Summary

Modifier and Type	Method	Description
MetadataMessage	getMetadataMessage(String bootstrapServers, Properties originalClientProperties)	Get the metadata message from the Kafka cluster.

Methods inherited from class java.lang.Object

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

Constructor Details

MetadataConsumer

public MetadataConsumer()

Method Details

getMetadataMessage

public MetadataMessage getMetadataMessage(String bootstrapServers,
 Properties originalClientProperties)

Get the metadata message from the Kafka cluster.

Parameters:

bootstrapServers - The Kafka bootstrap servers

Returns:

The metadata message, or null if there was an error