Constants

  • 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.

  • AUTH_SASL_PLAIN string "PLAIN"
  • Kafka SASL_PLAIN authentication mechanism

  • COMPRESSION_GZIP string "gzip"
  • Kafka GZIP compression type.

  • COMPRESSION_LZ4 string "lz4"
  • Kafka LZ4 compression type.

  • COMPRESSION_NONE string "none"
  • No compression.

  • COMPRESSION_SNAPPY string "snappy"
  • Kafka Snappy compression type.

  • COMPRESSION_ZSTD string "zstd"
  • Kafka ZSTD compression type.

  • DEFAULT_URL string "localhost:9092"
  • The default server URL.

  • DES_AVRO string "AVRO"
  • Apache Avro deserializer.

  • DES_BYTE_ARRAY string "BYTE_ARRAY"
  • In-built Kafka byte array deserializer.

  • DES_CUSTOM string "CUSTOM"
  • User-defined deserializer.

  • DES_FLOAT string "FLOAT"
  • In-built Kafka float deserializer.

  • DES_INT string "INT"
  • In-built Kafka int deserializer.

  • DES_STRING string "STRING"
  • In-built Kafka string 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.

  • OFFSET_RESET_EARLIEST string "earliest"
  • Automatically reset the consumer offset to the earliest offset

  • OFFSET_RESET_LATEST string "latest"
  • Automatically reset the consumer offset to the latest offset

  • OFFSET_RESET_NONE string "none"
  • If the offsetReset is set to OFFSET_RESET_NONE, the consumer will give an error if no previous offset is found for the consumer group

  • PROTOCOL_PLAINTEXT string "PLAINTEXT"
  • Represents Kafka un-authenticated, non-encrypted channel

  • PROTOCOL_SASL_PLAINTEXT string "SASL_PLAINTEXT"
  • Represents Kafka authenticated, non-encrypted channel

  • PROTOCOL_SASL_SSL string "SASL_SSL"
  • Represents Kafka SASL authenticated, SSL channel

  • PROTOCOL_SSL string "SSL"
  • Represents Kafka SSL channel

  • SER_AVRO string "AVRO"
  • Apache Avro serializer.

  • SER_BYTE_ARRAY string "BYTE_ARRAY"
  • In-built Kafka Byte Array serializer.

  • SER_CUSTOM string "CUSTOM"
  • User-defined serializer.

  • SER_FLOAT string "FLOAT"
  • In-built Kafka float serializer.

  • SER_INT string "INT"
  • In-built Kafka int serializer.

  • SER_STRING string "STRING"
  • In-built Kafka string serializer.