Package io.confluent.telemetry.events.exporter.kafka.async

Interface TopicSupplier<T>

All Known Implementing Classes:
SingleTopicSupplier
public interface TopicSupplier<T>

  • Method Summary

    Modifier and Type
    Method
    Description
    Optional<String>
    topic(T data)
    Get a topic for the record.

  • Method Details

    • topic

      Optional<String> topic(T data)
      Get a topic for the record. This allows us to get the topic management out of the exporter and makes it possible to extend the exporter for any kind of topic management and routing schemes. For eg - manage single topics for default case and send all data to the same topic - manage multiple topics with reconfiguration and send data to topics based on route extension - manage multiple topics and send data to topics based on feed labels
      Parameters:
      data -
      Returns:
      topic to send the data, if topic is empty, drop the data.