Fix missing Kafka key.

This commit is contained in:
Orne Brocaar 2022-08-30 16:45:33 +01:00
parent 4f08f7ddcb
commit 7e6552df5e

View File

@ -62,6 +62,10 @@ pub async fn setup() -> Result<()> {
.await
.context("Setup AMQP integration")?,
)),
"kafka" => integrations.push(Box::new(
kafka::Integration::new(&conf.integration.kafka)
.context("Setup Kafka integration")?,
)),
_ => {
return Err(anyhow!("Unexpected integration: {}", name));
}