Constants -
kafka
- DES_BYTE_ARRAY string BYTE_ARRAY
-
In-built Kafka byte array deserializer.
- DES_STRING string STRING
-
In-built Kafka string deserializer.
- DES_INT string INT
-
In-built Kafka int deserializer.
- DES_FLOAT string FLOAT
-
In-built Kafka float deserializer.
- DES_CUSTOM string CUSTOM
-
User-defined deserializer.
- DES_AVRO string AVRO
-
Apache Avro deserializer.
- ISOLATION_COMMITTED string read_committed
-
Configures the consumer to read the committed messages only in the transactional mode when poll() is called.
- ISOLATION_UNCOMMITTED string read_uncommitted
-
Configures the consumer to read all the messages including the aborted ones.
- ACKS_ALL string all
-
Producer acknowledgement type is 'all'. This will guarantee that the record will not be lost as long as at least one in-sync replica is alive.
- ACKS_NONE string 0
-
Producer acknowledgement type '0'. If the acknowledgement type set to this, the producer will not wait for any acknowledgement from the server.
- ACKS_SINGLE string 1
-
Producer acknowledgement type '1'. If the acknowledgement type set to this, the leader will write the record to its A local log will respond without waiting FOR full acknowledgement from all the followers.
- SER_BYTE_ARRAY string BYTE_ARRAY
-
In-built Kafka Byte Array serializer.
- SER_STRING string STRING
-
In-built Kafka string serializer.
- SER_INT string INT
-
In-built Kafka int serializer.
- SER_FLOAT string FLOAT
-
In-built Kafka float serializer.
- SER_CUSTOM string CUSTOM
-
User-defined serializer.
- SER_AVRO string AVRO
-
Apache Avro serializer.
- COMPRESSION_NONE string none
-
No compression.
- COMPRESSION_GZIP string gzip
-
Kafka GZIP compression type.
- COMPRESSION_SNAPPY string snappy
-
Kafka Snappy compression type.
- COMPRESSION_LZ4 string lz4
-
Kafka LZ4 compression type.
- COMPRESSION_ZSTD string zstd
-
Kafka ZSTD compression type.
- AUTH_SASL_PLAIN string PLAIN
-
Kafka SASL_PLAIN authentication mechanism
- PROTOCOL_SASL_PLAINTEXT string SASL_PLAINTEXT
- PROTOCOL_SASL_SSL string SASL_SSL
- CONSUMER_ERROR string {ballerina/kafka}ConsumerError
-
Used as the error reason for the
kafka:ConsumerError
type.
- PRODUCER_ERROR string {ballerina/kafka}ProducerError
-
Used as the error reason for the
kafka:ProducerError
type.
- AVRO_ERROR string {ballerina/kafka}AvroError
-
Used as the error reason for the
kafka:AvroError
type.