Class MessagingTransformer<K,V,R>
java.lang.Object
org.springframework.kafka.streams.messaging.MessagingTransformer<K,V,R>
- Type Parameters:
K
- the key type.V
- the value type.R
- the result value type.
- All Implemented Interfaces:
org.apache.kafka.streams.kstream.Transformer<K,
V, org.apache.kafka.streams.KeyValue<K, R>>
@Deprecated
public class MessagingTransformer<K,V,R>
extends Object
implements org.apache.kafka.streams.kstream.Transformer<K,V,org.apache.kafka.streams.KeyValue<K,R>>
Deprecated.
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 Summary
ConstructorDescriptionMessagingTransformer
(MessagingFunction function, MessagingMessageConverter converter) Deprecated.Construct an instance with the provided function and converter. -
Method Summary
-
Constructor Details
-
MessagingTransformer
Deprecated.Construct an instance with the provided function and converter.- Parameters:
function
- the function.converter
- the converter.
-
-
Method Details
-
init
public void init(org.apache.kafka.streams.processor.ProcessorContext context) Deprecated. -
transform
Deprecated. -
close
public void close()Deprecated.
-
MessagingProcessor
.