Nucrea/Hermes
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove kafka topic autocreation

Browse Source
This commit is contained in:
Sergey Chubaryan 2025-02-07 12:03:46 +03:00
parent cf01b1e36f
commit 5baf5ed7e9
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/integrations/kafka.go
View File

@ -16,7 +16,7 @@ func NewKafka(addr, topic string) *Kafka {
Addr: kafka.TCP(addr), Addr: kafka.TCP(addr),
Topic: topic, Topic: topic,
Balancer: &kafka.RoundRobin{}, Balancer: &kafka.RoundRobin{},
AllowAutoTopicCreation: true, AllowAutoTopicCreation: false,
BatchSize: 100, BatchSize: 100,
BatchTimeout: 100 * time.Millisecond, BatchTimeout: 100 * time.Millisecond,
} }