Prerequisites

• I have searched issues to ensure it has not already been reported

Description

If we call CreateTopicIfNotExists multiple time with same topic name we have an error at creation.

Confluent.Kafka.KafkaException: 'CREATETOPICS worker failed to parse response: CreateTopics response protocol parse failure: Local: Bad message format'

%3|****|PROTOERR|rdkafka#producer-1| [thrd:main]: ssl://*****: Broker returned topic development-users multiple times

Steps to reproduce

1. Call CreateTopicIfNotExists with same topic name multiple time
2. Launch app

Expected behavior

Topic would be created

Actual behavior

An exception is thrown

KafkaFlow version

latest