KafkaControl
For each Broadcast message emitted by the Matching Engine, the KafkaControl value in the message defines how the message is to be handled by the Kafka Producer process.
Values
| Key | Value | Description |
|---|
| Send | 1 | If this bit is not set in KafkaControl, the Kafka Producer will not send a Kafka message for the Broadcast message - i.e., this bit should normally be set. |
| Recovery | 2 | If this bit is set in KafkaControl, the Kafka Producer will send the Kafka message on the topic that has been defined as its recovery topic. |
| Startup | 4 | This bit is used in Engine logic to prevent Kafka messages from being sent during the time that the Matching Engine is starting up and loading data from cache files or tsv files. See usage in te_engine.cc and te_broadcasts.cc. |
| StopProducer | 8 | If the Kafka Producer processes a Broadcast message with this bit set in KafkaControl, it will cause the Kafka Producer to shut down. |
| UniqueResponseId | 16 | Normally, the Kafka Producer using a response_id that matches the Kafka id of the transaction that generated the Broadcast message. If this bit is set in KafkaControl then the Kafka Prodcuer will generate a unique response_id for the Broadcast message. |
| Internal | 32 | If this bit is set in KafkaControl, the Kafka Producer will send the Kafka message on the topic that has been defined as its internal topic. |
| SendReloaded | 64 | Normally, records that are reloaded (when starting from cache files or tsv files), they are not sent as Kafka messages. If this bit is set in KafkaControl for a given Broadcast message that is for a reloaded record, it will cause a Kafka message to be sent for that Broadcast message. |
Referenced by
Tables
Messages