java - 如何使用外部配置初始化 kafka 流自定义分区器

Question

根据价值和外部配置，我想决定分区。这里没有办法用外部配置初始化类。

class BookAwarePartitioner implements StreamPartitioner {

  @Override
  public Integer partition(String topic, Object key, Object value, int numPartitions) {
    return null;
  }
}

需要帮助来使用一些外部配置初始化此类。

标签： javaapache-kafkaapache-kafka-streams