v1.2.2
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 even 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.
-
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.