|
| 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
|
||||||||