|
|
| 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 |
|
|
Top
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
|
|||||||||
Progress® OpenEdge® Release 12.5.0