hoernschen/dendrite
1
0
Fork 0
mirror of https://github.com/hoernschen/dendrite.git synced 2025-08-02 06:12:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update saramajetstream

Browse source
This commit is contained in:
Till Faelligen 2021-07-09 08:16:33 +02:00
parent 1533c648e3
commit 341351c75a
3 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
setup/kafka/kafka.go
View file

@ -108,7 +108,7 @@ func setupNATS(cfg *config.Kafka) (sarama.Consumer, sarama.SyncProducer) {
}
}
consumer := js.NewJetStreamConsumer(s, cfg.TopicPrefix)
producer := js.NewJetStreamProducer(s, cfg.TopicPrefix)
consumer := js.NewJetStreamConsumer(nc, s, cfg.TopicPrefix)
producer := js.NewJetStreamProducer(nc, s, cfg.TopicPrefix)
return consumer, producer
}