Create a streaming mapping to read data from the Kafka queues that stream data in JSON, XML, CSV, or Avro formats.
Add a Lookup transformation to get data from a particular customer ID.
Add a Window transformation to accumulate the streamed data into data groups before processing the data.
Process the data. Add an Aggregator transformation to perform aggregations on the data from the customer ID.
Monitor jobs. Monitor statistics for the mapping job on the Monitoring tab of the Administrator tool.