11 OBDX-OBO Kafka consumer configuration

This topic provides information on OBDX-OBO Kafka consumer configuration.

Below script use for verifying database based kafka consumer properties

Select * from DIGX_CFG_CONFIG_ALL_B where PROP_ID like ‘KAFKA_CONFIG. externalSystemAlertMessage'

For more information on fields, refer to the field description table.

Topic name : externalSystemAlertMessage

Table 11-1 Origination related database entries

PROP_ID PROP_VALUE Description
KAFKA_CONFIG.externalSystemAlertMessage@auto.commit.interval.ms 1000 A commit is triggered after 1,000 messages
KAFKA_CONFIG.externalSystemAlertMessage@auto.offset.reset earliest / latest Is it always going to start consuming from start or last checkpoint
KAFKA_CONFIG.externalSystemAlertMessage@bootstrap.servers List of host/port pairs to use for establishing the initial connection to the Kafka cluster.
KAFKA_CONFIG.externalSystemAlertMessage@enable.auto.commit false If set to
true
, the consumer's offset will be periodically committed in the background.
KAFKA_CONFIG.externalSystemAlertMessage@group.id obdx-obo-consumer Name of the group that the consumer joins to read messages from a given topic or topics.
KAFKA_CONFIG.externalSystemAlertMessage@sasl.jaas.config org.apache.kafka.common.security.scram.ScramLoginModule required username="xxx" password="xxx"; This configuration property used to specify the Java Authentication and Authorization Service (JAAS) configuration for SASL authentication in Kafka
KAFKA_CONFIG.externalSystemAlertMessage@sasl.mechanism SCRAM-SHA-256 This configuration property used to specify the Java Authentication and Authorization Service (JAAS) configuration for SASL authentication in Kafka
KAFKA_CONFIG.externalSystemAlertMessage@security.protocol SASL_SSL Type of Security protocol
KAFKA_CONFIG.externalSystemAlertMessage@session.timeout.ms 30000 Session timeout in milliseconds
KAFKA_CONFIG.externalSystemAlertMessage@ssl.endpoint.identification.algorithm SSL Algorithm
KAFKA_CONFIG.externalSystemAlertMessage@ssl.truststore.location /scratch/app/domain/obdx_domain/KafkaServerKeystore.jks SSL Location
KAFKA_CONFIG.externalSystemAlertMessage@ssl.truststore.password SSL password
KAFKA_CONFIG.externalSystemAlertMessage@target.unit OBDX_BU Entity name