☰
Navigation :

Tuple Source

note

DLC provides a default TupleSourceDescription with the name defaultTupleSourceDesc. The only reason to make a new TupleSourceDescription is to organize topics logically.

Configuration Properties

Properties for a Tuple Source are defined by name in the dlc.tuple.sources namespace, and are picked up as configurations for the DLC.

Key Required Type Description
topics-to-include Set<String> Topics to include.
topics-to-exclude Set<String> Topics to exclude.

YAML Example 

dlc:
  tuple:
    sources:
      tupleSource:
        topics-to-include:
          - topic

Java Configuration

TupleSourceDescription Spring Beans are picked up as configurations for the DLC.

Parameter Required Type Description
name Y String Name of the source.
topicsToInclude Set<String> Topics to include.
topicsToExclude Set<String> Topics to exclude.

Java Example 

@Bean
TupleSourceDescription source() {
    return TupleSourceDescription.builder("tupleSource")
            .topicsToInclude(Set.of("topic"))
            .build();
}