diff --git a/symfony-bundles/kafka-bundle/1.0/config/packages/sb_kafka.yaml b/symfony-bundles/kafka-bundle/1.0/config/packages/sb_kafka.yaml new file mode 100644 index 00000000..3f80d77d --- /dev/null +++ b/symfony-bundles/kafka-bundle/1.0/config/packages/sb_kafka.yaml @@ -0,0 +1,17 @@ +sb_kafka: + producers: + configuration: + group.id: 'main_group' + log.connection.close: 'false' + metadata.broker.list: '%env(resolve:KAFKA_BROKERS)%' + queue.buffering.max.messages: 10000000 + + consumers: + configuration: + group.id: 'main_group' + log.connection.close: 'false' + metadata.broker.list: '%env(resolve:KAFKA_BROKERS)%' + + topics: + configuration: + auto.offset.reset: smallest diff --git a/symfony-bundles/kafka-bundle/1.0/manifest.json b/symfony-bundles/kafka-bundle/1.0/manifest.json index 59a0265c..abad2562 100644 --- a/symfony-bundles/kafka-bundle/1.0/manifest.json +++ b/symfony-bundles/kafka-bundle/1.0/manifest.json @@ -2,6 +2,9 @@ "bundles": { "SymfonyBundles\\KafkaBundle\\SymfonyBundlesKafkaBundle": ["all"] }, + "copy-from-recipe": { + "config/": "%CONFIG_DIR%/" + }, "env": { "KAFKA_BROKERS": "kafka.intra:9092" }