public class MessageMetadataSchemeAsMultiScheme extends SchemeAsMultiScheme
scheme
Constructor and Description |
---|
MessageMetadataSchemeAsMultiScheme(MessageMetadataScheme scheme) |
Modifier and Type | Method and Description |
---|---|
Iterable<List<Object>> |
deserializeMessageWithMetadata(ByteBuffer message,
Partition partition,
long offset) |
deserialize, getOutputFields
public MessageMetadataSchemeAsMultiScheme(MessageMetadataScheme scheme)
public Iterable<List<Object>> deserializeMessageWithMetadata(ByteBuffer message, Partition partition, long offset)
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.