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.