Skip to content

Commit 2eaed0f

Browse files
committed
Updated the kafka symfony configuration
1 parent d636cab commit 2eaed0f

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

pkg/rdkafka/Symfony/RdKafkaTransportFactory.php

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,14 +39,17 @@ public function addConfiguration(ArrayNodeDefinition $builder)
3939
return ['dsn' => $v];
4040
})
4141
->end()
42-
->fixXmlConfig('topic')
4342
->children()
4443
->scalarNode('dsn')
4544
->info('The kafka DSN. Other parameters are ignored if set')
4645
->end()
47-
->variableNode('global')->defaultValue([])->end()
48-
->arrayNode('topics')
49-
->prototype('scalar')->end()
46+
->variableNode('global')
47+
->defaultValue([])
48+
->info('The kafka global configuration properties')
49+
->end()
50+
->variableNode('topic')
51+
->defaultValue([])
52+
->info('The kafka topic configuration properties')
5053
->end()
5154
->scalarNode('dr_msg_cb')
5255
->info('Delivery report callback')

0 commit comments

Comments
 (0)