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_FW_CONFIG_ALL_B where PROP_ID like ‘externalSystermAlertMessage%’

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

Table 11-1 Origination related database entries

PROP_ID PROP_VALUE Description
externalSystemAlertMessage@auto.commit.interval.ms 1000 A commit is triggered after 1,000 messages
externalSystemAlertMessage@auto.offset.reset earliest / latest Is it always going to start consuming from start or last checkpoint
externalSystemAlertMessage@bootstrap.servers List of host/port pairs to use for establishing the initial connection to the Kafka cluster.
externalSystemAlertMessage@enable.auto.commit false If set to 
true
, the consumer's offset will be periodically committed in the background.
externalSystemAlertMessage@group.id obdx-obo-consumer Name of the group that the consumer joins to read messages from a given topic or topics.
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
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
externalSystemAlertMessage@security.protocol SASL_SSL Type of Security protocol
externalSystemAlertMessage@session.timeout.ms 30000 Session timeout in milliseconds
externalSystemAlertMessage@ssl.endpoint.identification.algorithm SSL Algorithm
externalSystemAlertMessage@ssl.truststore.location /scratch/app/domain/obdx_domain/KafkaServerKeystore.jks SSL Location
externalSystemAlertMessage@ssl.truststore.password SSL password
externalSystemAlertMessage@target.unit OBDX_BU Entity name

Please follow following steps

  1. Login into Weblogicconsole.
  2. Click onDeployments.
  3. Expand by clicking ‘+’ icon present in front of com.ofss.digx.app.connectorapplication as shown below.
    Description of rpm4.png follows
    Description of the illustration rpm4.png

  4. Click com.ofss.digx.connector.rar as shown below.
    Description of rpm5.png follows
    Description of the illustration rpm5.png

  5. Click ‘Security’ tab and then click ‘Outbound Credential Mappings’ sub tab as shown below.
    Description of rpm6.png follows
    Description of the illustration rpm6.png

  6. Click on ‘New’ button. Following screen will be appearing.
    Description of rpm7.png follows
    Description of the illustration rpm7.png

  7. Select ‘ra/DIGXConnectorAES’ .
  8. Click ‘Next’ button. Following screen will be appearing.
    Description of rpm8.png follows
    Description of the illustration rpm8.png

  9. Select ‘Default User’ .
  10. Click ‘Next’ button. Following screen will be appearing.
    Description of rpm9.png follows
    Description of the illustration rpm9.png

  11. Enter following details and then click ‘Finish’ button.
    • EISUser Name → AES_KEY
    • EISPassword →“Desired password”
    • Confirm Password → “Desired password”
  12. Restart the manage server to activate the changes.