Interface TopicIdLookup

Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface TopicIdLookup
Functional interface for looking up topic IDs.

This interface abstracts the metadata cache dependency, allowing the Odyssey module to remain decoupled from the Kafka core module. The core module provides an implementation (e.g., KRaftMetadataCache::getTopicId) when creating the integration manager.

Thread Safety:

Implementations must be thread-safe as lookups may occur from multiple threads.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.common.Uuid
    getTopicId(String topicName)
    Look up the topic ID for a given topic name.

  • Method Details

    • getTopicId

      org.apache.kafka.common.Uuid getTopicId(String topicName)
      Look up the topic ID for a given topic name.
      Parameters:
      topicName - the name of the topic
      Returns:
      the topic's UUID, or null if not found