Kafka Configuration

Prev

I use Kafka for keeping users’ requests for melanoma prediction. I need broker because my data flow is asynchronous with reference to long request processing for prediction.

I use Java stack for sending messages to Kafka and receiving message from message queue system.

Kafka communication diagram

The following table contains my Kafka configuration values, which I use for MoleCare project.

The structure of my message in Kafka is presented in Figure 1. Moreover, I use String serialization and deserialization in topic of the message system. The message contains json format of json serialized model KafkaModel.

Figure 1 KafkaModel — model of the message in message system