Enabling Kafka for Event Streaming
Apply configuration similar to the following in a ConfigMap specified in your Helm values file or provided in a ConfigMap-based configuration source.
mp.messaging.incoming.mtx-event-in.connector: smallrye-kafka
mp.messaging.incoming.mtx-event-in.enabled: true
mp.messaging.incoming.mtx-event-in.topic: mdc-event
mp.messaging.incoming.mtx-event-in.key.deserializer: org.apache.kafka.common.serialization.StringDeserializer
mp.messaging.incoming.mtx-event-in.value.deserializer: org.apache.kafka.common.serialization.StringDeserializer
kafka.bootstrap.servers: kafka:29092
Kafka Configuration Properties describes the configuration
properties.
Config | Descriptions |
---|---|
mp.messaging.incoming.mtx-event-in.connector | The name of the Kafka connector. This must be
smallrye-kafka . |
mp.messaging.incoming.mtx-event-in.enabled | Set to false to disable event streaming with
Kafka. Streaming is enabled by default if this property is not
set or is not present. |
mp.messaging.incoming.mtx-event-in.topic | The topic name to which the Kafka consumer subscribes. For example, mdc-event. |
mp.messaging.incoming.mtx-event-in.key.deserializer | The interface for wrapping a serializer and deserializer for the MTX event key. |
mp.messaging.incoming.mtx-event-in.value.deserializer | The interface for wrapping a serializer and deserializer for the MTX event key/value. |
kafka.bootstrap.servers | A comma-separated list of host and port pairs that are the addresses of the Kafka brokers in a bootstrap Kafka cluster to which the Kafka client connects to bootstrap itself. |
For more information, see the discussion about applying configuration with ConfigMaps in MATRIXX Installation and Upgrade.