Farfetch / kafkaflow-retry-extensions

Kafka Flow Retry Patterns Extensions

https://farfetch.github.io/kafkaflow-retry-extensions/

MIT License

55 stars 7 forks source link

chore: creating test topics if they does not exist #101

Closed fernando-a-marins closed 1 year ago

fernando-a-marins commented 1 year ago

Description

creating test topics if they does not exist in the kafka bootsrapper

Checklist

[x] My code follows the style guidelines of this project
[x] I have performed a self-review of my own code
[ ] I have added tests to cover my changes
[ ] I have made corresponding changes to the documentation

Disclaimer

By sending us your contributions, you are agreeing that your contribution is made subject to the terms of our Contributor Ownership Statement

gsferreira commented 1 year ago

@fernando-a-marins are you aware of this in KafkaFlow? https://github.com/Farfetch/kafkaflow/blob/f47446042bc58606f3af92c0163f9fa9358697e6/samples/KafkaFlow.Sample/Program.cs#L21

        .AddCluster(
            cluster => cluster
                .WithBrokers(new[] { "localhost:9092" })
                .CreateTopicIfNotExists(topicName, 6, 1)