com.opendxl.streaming.client.entity

Class ConsumerRecords.ConsumerRecordMessage

java.lang.Object

com.opendxl.streaming.client.entity.ConsumerRecords.ConsumerRecordMessage

Enclosing class:

ConsumerRecords

public static class ConsumerRecords.ConsumerRecordMessage
extends java.lang.Object

Headers and payload of the consumed record.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordMessage()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.String>	getHeaders() Gets the record headers.
java.lang.String	getPayload() Gets the record payload.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConsumerRecordMessage

public ConsumerRecordMessage()

Method Detail

getPayload

public java.lang.String getPayload()

Gets the record payload.

Returns:

the record payload

getHeaders

public java.util.Map<java.lang.String,java.lang.String> getHeaders()

Gets the record headers.

Returns:

the record headers