|
Options |
Name |
Purpose |
|
|
|
OpenEdge.Messaging.IProducer Build ()
|
/**
Build a kafka producer.
*/
|
|
|
|
CopyOptionsToBIO (IStringStringMap, IMessageClientDelegate)
|
/**
Copy options to the built-in producer.
This does not pass UNKNOWN value to kafka, rather lets Kafka keep its default value
and behavior if any options that would normally go to Kafka are currently set as unknown.
*/
|
|
|
|
CopyOptionsToProducerMap (IStringStringMap)
|
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder Create ()
|
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducer CreateKafkaProducer (IProducerDelegate, IStringStringMap, IStringKeyedMap)
|
/*
Create a kafka producer. Marked as protected so it can be unit tested.
*/
|
|
|
|
OpenEdge.Messaging.ISerializer CreateKeySerializer ()
|
/**
Construct a key serializer for the producer.
*/
|
|
|
|
OpenEdge.Messaging.Internal.IProducerDelegate CreateProducerDelegate ()
|
/*
Create the BIO producer. This is marked as protected so it can be overridden for unit tests.
*/
|
|
|
|
OpenEdge.Messaging.ISerializer CreateSerializer (character)
|
/**
Construct a serializer from the given property name. The property stored in the config
may be either an instance of the serializer, in which case the instance itself is returned,
or the name of class that implements ISerializer, in which case, an new instance of the identified
class is constructed and returned.
*/
|
|
|
|
OpenEdge.Messaging.ISerializer CreateValueSerializer ()
|
/**
construct a value serializer for the producer.
*/
|
|
|
|
LOGICAL FilterOption (character)
|
/**
@Override
*/
|
|
|
|
Progress.Lang.Object GetOptionAsObject (character)
|
/*
Override for GetOptionStringValue from ConfigBuilder to make it easier to access
from utility functions.
*/
|
|
|
|
Progress.Lang.Object GetOptionObjectValue (character)
|
/**
Override for GetOptionStringValue from ConfigBuilder to make it easier to access
from utility functions.
*/
|
|
|
|
CHARACTER GetOptionStringValue (character)
|
/**
Override for GetOptionStringValue from ConfigBuilder to make it easier to access
from utility functions.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetAcks (Acks)
|
/**
set number of acknowledgements needed by default
before broker responds to consumer when record(s)
are sent.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetAcks (integer)
|
/**
Set number of acknowledgements needed by default
before broker responds to consumer when record(s)
are sent.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetBootstrapServers (character)
|
/*
Configure the producer with an initial list of Kafka brokers to which
to connect.
The format of the string is expected to be a comma delimited list in the form of
<host>:<port>[,<host>:<port>...]
@param boostraServers The bootstrap server value
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetBootstrapServers (URI)
|
/**
Configure the producer with an initial Kafka broker to which
to connect. Each URI needs to provide a host and port which is
used to locate a Kafka broker
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetBootstrapServers (URI[])
|
/*
Configure the producer with an initial list of Kafka brokers to which
to connect. The URI needs to provide a host and port that will be used
to locate a Kafka broker.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetClientId (character)
|
/**
Set the client id the client uses to identify itself to the server.
@param clientId Set client id.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetEnableIdempotence (logical)
|
/**
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetKeySerializer (character)
|
/**
Provide the name of a class which must implement OpenEdge.Messaging.ISerializer.
An instance of this class will be created to convert the message partition key values
to MEMPTR.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetKeySerializer (ISerializer)
|
/**
Provide an implementation of a serializer that will be used to convert
the message partition key values to MEMPTR.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetKeySerializerCodePage (character)
|
/**
Set the codepage used to serialize string based message partition keys.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetMessageMaxBytes (integer)
|
/**
Set the maximum number of message bytes allowed by the producer
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetMessageSendMaxRetries (integer)
|
/**
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetQueueBufferingMaxKBytes (integer)
|
/**
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetQueueBufferingMaxMessages (integer)
|
/**
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetQueueBufferingMaxMs (int64)
|
/**
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetSASLMechanism (SASLMechanisms)
|
/**
Set the security mechanism to be used by the producer.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetSASLPassword (character)
|
/**
Set the SASL password.
@param saslPassword The password
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetSASLUserName (character)
|
/**
Set the security username to be used by the producer.
@param saslUserName The security username .
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetSecurityProtocol (character)
|
/**
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetSecurityProtocol (SecurityProtocol)
|
/**
Set security protocol used by the connection to the cluster.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetStrictConfigNames (logical)
|
/*
Specify whether errors from kafka broker that indicate unsupported configuration names
are returned to the ABL as an error, or if the error is quietly ignored.
@param enforceStrictConfigNames whether to enforce strict config names.
@return This producer builder.
*/
|
|
|
|
OpenEdge.Messaging.Kafka.KafkaProducerBuilder SetTransactionalId (character)
|
/**
@return This producer builder.
*/
|