Package org.springframework.cloud.stream.binder.kafka.streams.annotations

Interface KafkaStreamsProcessor

public interface KafkaStreamsProcessor
Bindable interface for KStream input and output. This interface can be used as a bindable interface with EnableBinding when both input and output types are single KStream. In other scenarios where multiple types are required, other similar bindable interfaces can be created and used. For example, there are cases in which multiple KStreams are required on the outbound in the case of KStream branching or multiple input types are required either in the form of multiple KStreams and a combination of KStreams and KTables. In those cases, new bindable interfaces compatible with the requirements must be created. Here are some examples. 
     interface KStreamBranchProcessor {
         @Input("input")
         KStream<?, ?> input();

         @Output("output-1")
         KStream<?, ?> output1();

         @Output("output-2")
         KStream<?, ?> output2();

         @Output("output-3")
         KStream<?, ?> output3();

         ......

     }

     interface KStreamKtableProcessor {
         @Input("input-1")
         KStream<?, ?> input1();

         @Input("input-2")
         KTable<?, ?> input2();

         @Output("output")
         KStream<?, ?> output();

         ......

     }
Author:
Marius Bogoevici, Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.streams.kstream.KStream<?,?>
    input()
    Input binding.
    org.apache.kafka.streams.kstream.KStream<?,?>
    output()
    Output binding.

  • Method Details

    • input

      @Input("input") org.apache.kafka.streams.kstream.KStream<?,?> input()
      Input binding.
      Returns:
      Input binding for KStream type.

    • output

      @Output("output") org.apache.kafka.streams.kstream.KStream<?,?> output()
      Output binding.
      Returns:
      Output binding for KStream type.