ssl-hep/ServiceX_App

Create Kafka Topics

Closed this issue · 0 comments

Story

As an analyzer I want Kafka topics to be created with the correct parameters so I can perform my analysis efficiently

Acceptance Criteria

  1. Given I have a submitted transformation request, when it passes preflight checks, then a Kafka topic should be created that ha the correct number of partitions and max.message.bytes

Assumptions

  1. Partitions is a setting in app.conf
  2. max.message.bytes set with current heuristic of 40 bytes/column/event