问 如何使用DelphiKafkaClient (或librdkafka.dll)通配符订阅卡夫卡主题？

EN

我使用的是DelphiKafkaClient ( https://github.com/norgepaul/DelphiKafkaClient )，它是Apache (librdkafka.dll)的包装器。

在创建新的使用者并指定要订阅的主题名称(在 TKafkaFactory.NewConsumer 中)时，普通名称工作得很好，但是regex通配符似乎不起作用( ^* 、 * 、 # 、 ^.* 或其他任何东西)。

下面是来自DelphiKafkaClient的相关代码(请参阅我的评论)：

procedure TKafkaConsumerThread.DoSetup;
  i: Integer;
  TopicList: prd_kafka_topic_partition_list_t;
  err: rd_kafka_resp_err_t;
begin
  FKafkaHandle := TKafkaHelper.NewConsumer(FConfiguration);
  if rd_kafka_brokers_add(FKafkaHandle, PAnsiChar(AnsiString(FBrokers))) = 0 then
  begin
    raise EKafkaError.Create(StrBrokersCouldNotBe);
  rd_kafka_poll_set_consumer(FKafkaHandle);
  TopicList := rd_kafka_topic_partition_list_new(0);
  for i := Low(FTopics) to High(FTopics) do
  begin
    rd_kafka_topic_partition_list_add(
      TopicList,
      PAnsiChar(AnsiString(FTopics[i])), // 'test' works, '^*' does not
      FPartitions[i]);