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
-
Consumer isolation level value 'read_committed'
- ISOLATION_UNCOMMITTED string read_uncommitted
-
Consumer isolation level value 'read_uncommitted'
- ACKS_ALL string all
-
Producer acknowledgement type 'all'. This will gurantee 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 local log but will respond without awaiting full acknowledgement from all 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
-
Kafka compression type. Value 'none'
- COMPRESSION_GZIP string gzip
-
Kafka compression type. Value 'gzip'
- COMPRESSION_SNAPPY string snappy
-
Kafka compression type. Value 'snappy'
- COMPRESSION_LZ4 string lz4
-
Kafka compression type. Value 'lz4'
- COMPRESSION_ZSTD string zstd
-
Kafka compression type. Value 'zstd'
- CONSUMER_ERROR string {ballerina/kafka}ConsumerError
-
Defines a Kafka consumer related error
- PRODUCER_ERROR string {ballerina/kafka}ProducerError
-
Defines a Kafka producer related error
- AVRO_ERROR string {ballerina/kafka}AvroError
-
Defines an Avro serialization / deserialization error