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 , 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 |