| 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 © 2021 The Apache Software Foundation. All rights reserved.