Clojurians Log v2

Hey, we can't create the same topic more than once right?

I'm having an issue creating topics and starting the kafka stream with integrant...

like I added the topics and create-topic method inside the intregant init-key method and now whenever I run the app, it says topic already exists

so how can I just create the topic once and use it for producing and consuming...

Not sure exactly how you create the topics now. In the cli there is an additional option to skip existing topics

--if-not-exists                          if set when creating topics, the action will only execute if the topic does not already exist. Not supported with the --bootstrap-server option.

But if the documentation is correct then it’s a bit weird, since --bootstrap-server should always be used..