Class | Description |
---|---|
ByteArrayMessageMapper | |
StringMessageMapper |
Given a String topic and byte[] message, emits a tuple with fields “topic” and “message”, both of which are Strings.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.