Post: Kafka Prediction

Endpoint: /prediction/kafka_prediction

Generates a prediction by streaming data through the trained ML model. This enables immediate decision-making and continuous analysis as data arrives.

Input Parameters:

  • usecaseId (string, required): Unique identifier for the dataset/use case.
  • usecaseVersion (integer, required): Version of the use case.
  • Topic(string, required): Kafka topic name is required
  • Totaldatapoints(integer, optional, default:1, min:1, max:1000): Number of messages to fetch
  • SID(integer, optional, default:1): Kafka broker setting ID
  • return_type (string, optional): return type for the prediction data (default : Json)
  • Valid payload based on the required prediction

Output:

Returns a JSON response with the predicted output for the provided kafka values.