Pārlūkot izejas kodu
Add KafkaOptions.MainConfig to AutoCreateTopic (#810)
Co-authored-by: Alexey Nikitin <Aleksey.Nikitin@domrf.ru>
master
Alexey Nikitin
pirms 3 gadiem
committed by
GitHub
vecāks
revīzija
8d6bd0f019
Šim parakstam datu bāzē netika atrasta zināma atslēga
GPG atslēgas ID: 4AEE18F83AFDEB23
1 mainītis faili ar
1 papildinājumiem un
1 dzēšanām
-
src/DotNetCore.CAP.Kafka/IProcessingServer.AutoCreateTopic.cs
|
|
@@ -31,7 +31,7 @@ namespace DotNetCore.CAP.Kafka |
|
|
|
{ |
|
|
|
try |
|
|
|
{ |
|
|
|
var config = new AdminClientConfig { BootstrapServers = _kafkaOptions.Servers }; |
|
|
|
var config = new AdminClientConfig(_kafkaOptions.MainConfig) { BootstrapServers = _kafkaOptions.Servers }; |
|
|
|
|
|
|
|
var topics = _selector.GetAllTopics(); |
|
|
|
|
|
|
|