jackdaw 2021-04-13 | Slack Archive

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

finchharold05:04:23

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

gklijs07:04:05

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.

gklijs07:04:23

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

2021-04-13

Channels