Package org.springframework.kafka.streams.messaging

Class MessagingProcessor<Kin,Vin,Kout,Vout>

java.lang.Object
org.apache.kafka.streams.processor.api.ContextualProcessor<Kin,Vin,Kout,Vout>
org.springframework.kafka.streams.messaging.MessagingProcessor<Kin,Vin,Kout,Vout>
Type Parameters:
Kin - the input key type.
Vin - the input value type.
Kout - the output key type.
Vout - the output value type.
All Implemented Interfaces:
org.apache.kafka.streams.processor.api.Processor<Kin,Vin,Kout,Vout>
public class MessagingProcessor<Kin,Vin,Kout,Vout> extends org.apache.kafka.streams.processor.api.ContextualProcessor<Kin,Vin,Kout,Vout>
A Transformer implementation that invokes a MessagingFunction converting to/from spring-messaging Message. Can be used, for example, to invoke a Spring Integration flow.
Since:
2.3
Author:
Gary Russell

  • Constructor Details

    • MessagingProcessor

      public MessagingProcessor(MessagingFunction function, MessagingMessageConverter converter)
      Construct an instance with the provided function and converter.
      Parameters:
      function - the function.
      converter - the converter.

  • Method Details

    • process

      public void process(org.apache.kafka.streams.processor.api.Record<Kin,Vin> record)

    • close

      public void close()