• The created Kafka topic is: graphrunner.ingest
• The consumer group is: graphrunner-group
• Mode-based broker resolution:
  • KAFKA_MODE=local → localhost:9092
  • KAFKA_MODE=docker → kafka:9092

The consumer listens for messages structured as it follows:

{
  "vertices": [...],
  "edges": [...]
}

These messages are validated and routed through the ingestion pipeline.