Namespace: OpenEdge.Messaging.Kafka
Class
KafkaRecordBuilder
Parent classes:
Inherits: OpenEdge.Messaging.RecordBuilder

/*
Copyright © 2021 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
Purpose:
A Kafka specific record builder.




Method Summary
Options Name Purpose
OpenEdge.Messaging.RecordBuilder SetPartitionId (integer) /** Set the partition id. The partition id may be unknown to allow the producer to assign it. The value cannot be negative. @param partition The partition id to which the produced record will be assigned. */
OpenEdge.Messaging.RecordBuilder SetPartitionKey (memptr) /** Assign the partition key used to create the ProducerRecord. This may be any memptr. @param partitionKey A memptr with a value that should be used as the partition key for the produced record. */
OpenEdge.Messaging.RecordBuilder SetPartitionKey (Object) /** Assign the partition key used to create the ProducerRecord. This may be any object or an uknown value. @param partitionKey An object that will be used as the partition key for the produced record. */


Method Detail
Top

OpenEdge.Messaging.RecordBuilder SetPartitionId (integer)

Purpose:
Set the partition id. The partition id may be unknown to allow the producer to assign it.
The value cannot be negative.
Parameters:
partitionId INTEGER
Returns OpenEdge.Messaging.RecordBuilder
Top

OpenEdge.Messaging.RecordBuilder SetPartitionKey (memptr)

Purpose:
Assign the partition key used to create the ProducerRecord.
This may be any memptr.
Parameters:
partitionKey MEMPTR
A memptr with a value that should be used as the partition key for the produced record.
Returns OpenEdge.Messaging.RecordBuilder
Top

OpenEdge.Messaging.RecordBuilder SetPartitionKey (Object)

Purpose:
Assign the partition key used to create the ProducerRecord.
This may be any object or an uknown value.
Parameters:
partitionKey Progress.Lang.Object
An object that will be used as the partition key for the produced record.
Returns OpenEdge.Messaging.RecordBuilder


Copyright © 2022 Progress Software Corporation. All rights Reserved.

Progress® OpenEdge® Release 12.5.0