search

triggermesh / brokers

TriggerMesh broker implementations: Redis backed and Memory
Apache License 2.0
6 stars 12 forks source link

[Kafka]soft ensure kafka topic #185

Closed odacremolbap closed 1 year ago

odacremolbap commented 1 year ago

Kafka topics might not exist when the broker is started.

When the broker starts try to create it. In case we fail to create it, it could still be that the topic exists but we do not have permissions on topics but to produce and consume, so we warn and move over.