Kafka: fix create topic

2021-08-13 11:09:01 +03:00 · 2021-08-13 11:09:01 +03:00 · 86248a3ad1
commit 86248a3ad1
parent 508bb59f0f
1 changed files with 3 additions and 1 deletions
--- a/common/ASC.Common/Caching/KafkaCache.cs
+++ b/common/ASC.Common/Caching/KafkaCache.cs
@ -128,7 +128,9 @@ namespace ASC.Common.Caching
                            {
                                new TopicSpecification 
                                { 
-                                    Name = channelName
+                                    Name = channelName,
+                                    NumPartitions = 1,
+                                    ReplicationFactor = 1
                                } 
                            }).Wait();
                }