我正在使用confluent kafka dotnet lib创建并生成以下主题:
producer.ProduceAsync(topic, key, message);
当此主题不存在时,将使用一个分区自动创建该主题。
但出于测试目的,我希望能够以编程方式创建一个包含n个分区的主题。
我在这里找不到任何示例(分支0.11.5),如何创建具有多个分区的主题?https://github.com/confluentinc/confluent-kafka-dotnet
我正在使用confluent kafka dotnet lib创建并生成以下主题:
producer.ProduceAsync(topic, key, message);
当此主题不存在时,将使用一个分区自动创建该主题。
但出于测试目的,我希望能够以编程方式创建一个包含n个分区的主题。
我在这里找不到任何示例(分支0.11.5),如何创建具有多个分区的主题?https://github.com/confluentinc/confluent-kafka-dotnet
1条答案
按热度按时间icomxhvb1#
由于我已经在使用docker,我发现在docker compose中创建一个测试主题(有n个分区)是最简单的:
它创建了带有3个分区的主题“partitionstest”。
警告:您的测试可能在主题创建之前执行。
一旦在合流kafka库的发布版本中提供了管理特性,我可能会更新它以使用这种方法。