用n个分区创建Kafka主题

siotufzp  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(355)

我正在使用confluent kafka dotnet lib创建并生成以下主题:

producer.ProduceAsync(topic, key, message);

当此主题不存在时,将使用一个分区自动创建该主题。
但出于测试目的,我希望能够以编程方式创建一个包含n个分区的主题。
我在这里找不到任何示例(分支0.11.5),如何创建具有多个分区的主题?https://github.com/confluentinc/confluent-kafka-dotnet

icomxhvb

icomxhvb1#

由于我已经在使用docker,我发现在docker compose中创建一个测试主题(有n个分区)是最简单的:

zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"

  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: kafka
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_CREATE_TOPICS: "PartitionsTest:3:1"
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
    links:
      - zookeeper

它创建了带有3个分区的主题“partitionstest”。
警告:您的测试可能在主题创建之前执行。
一旦在合流kafka库的发布版本中提供了管理特性,我可能会更新它以使用这种方法。

相关问题