Messaging Platform

This section explains the configuration of the messaging platform (Kafke).

Microservice is capable of accepting AVRO based events from Temenos Transact and processing them before inserting into the database. The ingester of the callback registry microservices performs this function. The messaging platform used by the callbackregistry microservices is Apache Kafka.

Configuration of Kafka in Ingester

You can configure the kafka in the dataIngester.properties file, which is available in ms-callbackregistry-data-ingester.war. Here, you should attach the screen capture of the properties file highlighting the required properties to be configured for kafka.

In the above properties file, you can see that some of the properties are pre-defined for kafka.

S.No	Property	Description
1	temn.msf.stream.vendor = kafka	Notifies the ingester that the streaming platform is kafka
2	temn.msf.schema.registry.url=http://10.93.23.52:8081	Points to the schema registry of kafka and you can use IP address or local host to point to it
3	temn.msf.stream.kafka.bootstrap.servers=10.93.23.52:29092	Connects to bootstrap server URL and you can use either IP address with port or kafka:29092 to connect
4	temn.msf.ingester.source.stream=if-callbackregistry	Defines the topic to which the ingester should subscribe to
5	temn.msf.ingest.error.stream=error-callbackregistry	Defines the error topic to which the errors occuring the ingester should be posted to
6	temn.msf.ingester.source.stream.consumergroup.id=test	Defines the consumer group id of kafka