|
Options | Name | Purpose | |
---|---|---|---|
KafkaConsumerRecord (ConsumerRecord) |
/**
Create a kafka consumer record. This accepts a BIO Consumer Record as we need
this to commit offsets.
*/
|
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 |
|
KafkaConsumerRecord (ConsumerRecord)
|
---|
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
|