MetadataCache

MetadataCache is…​FIXME

MetadataCache is created exclusively for KafkaServer (when started).

MetadataCache takes a single broker ID when created.

Table 1. MetadataCache’s Internal Properties (e.g. Registries, Counters and Flags)
Name Description

metadataSnapshot

partitionMetadataLock

Java’s ReentrantReadWriteLock

stateChangeLogger

StateChangeLogger

MetadataCache uses [MetadataCache brokerId=[brokerId]] as the logging prefix (aka logIdent).

Tip

Enable DEBUG or ERROR logging level for kafka.server.MetadataCache logger to see what happens inside.

Add the following line to config/log4j.properties:

log4j.logger.kafka.server.MetadataCache=DEBUG

Refer to Logging.

getAllTopics Method

getAllTopics(): Set[String]

getAllTopics…​FIXME

Note
getAllTopics is used when…​FIXME

getTopicMetadata Method

getTopicMetadata(
  topics: Set[String],
  listenerName: ListenerName,
  errorUnavailableEndpoints: Boolean = false,
  errorUnavailableListeners: Boolean = false): Seq[MetadataResponse.TopicMetadata]

getTopicMetadata…​FIXME

Note
getTopicMetadata is used when…​FIXME

results matching ""

    No results matching ""