Namespace: OpenEdge.Messaging.Kafka
Class
KafkaConsumerRecord
Parent classes:
Inherits: Progress.Lang.Object
Implements: OpenEdge.Messaging.IConsumerRecord

/*
Copyright © 2021 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
Purpose:
Create a kafka consumer record. This accepts a BIO Consumer Record as we need
this to commit offsets.



Constructor Summary
Options Name Purpose
KafkaConsumerRecord (ConsumerRecord) /** Create a kafka consumer record. This accepts a BIO Consumer Record as we need this to commit offsets. */

Property Summary
Options Name Purpose
Progress.Messaging.ConsumerRecord BioRecord
Progress.Lang.Object Body
OpenEdge.Messaging.IConsumer Consumer
OpenEdge.Messaging.IHeaders Headers
INT64 Offset
INTEGER PartitionId
Progress.Lang.Object PartitionKey
DATETIME-TZ Timestamp
CHARACTER TopicName


Constructor Detail
Top

KafkaConsumerRecord (ConsumerRecord)

Purpose:
Create a kafka consumer record. This accepts a BIO Consumer Record as we need
this to commit offsets.
Parameters:
bioRecord Progress.Messaging.ConsumerRecord


Property Detail
Top

Progress.Messaging.ConsumerRecord BioRecord

Returns Progress.Messaging.ConsumerRecord
Top

Progress.Lang.Object Body

Returns Progress.Lang.Object
Top

OpenEdge.Messaging.IConsumer Consumer

Returns OpenEdge.Messaging.IConsumer
Top

OpenEdge.Messaging.IHeaders Headers

Returns OpenEdge.Messaging.IHeaders
Top

INT64 Offset

Returns INT64
Top

INTEGER PartitionId

Returns INTEGER
Top

Progress.Lang.Object PartitionKey

Returns Progress.Lang.Object
Top

DATETIME-TZ Timestamp

Returns DATETIME-TZ
Top

CHARACTER TopicName

Returns CHARACTER


Copyright © 2022 Progress Software Corporation. All rights Reserved.

Progress® OpenEdge® Release 12.5.0