You run the IT department of a major bank that has millions of customers. You want to monitor network activity in real time. You need to collect network activity data from sources, such as firewalls or network devices to improve security and prevent attacks. The network activity data includes Denial of Service (DoS) attacks and failed login attempts made by customers. The network activity data is written to multiple Confluent Kafka topics with different schema definitions.

You can create one streaming mapping at design time. Configure the streaming mapping to refresh the Confluent Kafka schema registry to adjust the mapping to various sources and targets at run time. The latest schema is fetched from Confluent schema registry and used to synchronize the sources and targets.