从你的代码和描述来看，Java消费者明明已经完成订阅，却始终没触发分区分配，而控制台消费者却能正常工作，这大概率是正则匹配、元数据同步或者客户端版本的问题，我来帮你一步步排查：

1. 先确认正则表达式是否真的匹配目标主题 #

你在代码里用Pattern.compile(regex)订阅，但有没有可能传入的regex参数不对？比如是不是少写了*，或者写成了mytopic-而不是mytopic.*？

建议在createConsumer里加一行日志，把实际使用的正则打出来：

log.info("Subscribing to topics matching regex: {}", regex);

确保这个正则能精准匹配到mytopic-1——毕竟控制台消费者是直接指定主题，和正则订阅的逻辑不一样，这是最容易踩坑的点。

2. 旧版本Kafka客户端的元数据刷新bug #

你用的是kafka-client 2.0.0，这个版本在正则订阅时存在一个小问题：消费者不会主动立即刷新元数据去发现匹配的主题，而是要等默认的5分钟（metadata.max.age.ms默认值）才会刷新。

解决方法很简单，在订阅后手动触发一次元数据查询，强制消费者获取最新的主题列表：

consumer.subscribe(Pattern.compile(regex), listener);
// 手动查询某个匹配的主题，触发元数据刷新
consumer.partitionsFor("mytopic-1");
log.info("consumer subscribed");

这样消费者就能立刻发现mytopic-1，进而触发分区分配。

3. 调整元数据刷新频率（可选） #

如果你的环境中会经常新增符合正则的主题，建议把metadata.max.age.ms配置改小，比如设置成3000毫秒（3秒），让消费者更频繁地刷新元数据：

properties.put(ConsumerConfig.METADATA_MAX_AGE_MS_CONFIG, 3000);

这样后续新增的主题也能被及时发现。

4. 检查消费者组状态 #

有时候消费者组的协调器可能存在异常，导致分区分配失败。你可以用Kafka的命令行工具查看消费者组的状态：

kafka-consumer-groups.sh --bootstrap-server server1:9092 --describe --group mygroupid

如果输出显示No active members，说明你的Java消费者根本没成功加入消费者组，这时候要检查bootstrap.servers是否正确，网络是否能连通Kafka集群。

5. 确认poll循环确实在运行 #

最后再确认一下：createConsumer返回的消费者，是不是真的传入了startWorking方法，并且这个方法确实被执行了？比如有没有可能代码逻辑里漏掉了调用startWorking？

可以在startWorking方法开头加一行日志：

public <K, V> void startWorking(Consumer<K, V> consumer) {
    log.info("Starting poll loop for consumer in group: {}", consumer.groupMetadata().groupId());
    try {
        // ... 原有循环代码
    }
}

确保poll循环真的在跑——毕竟如果没开始poll，消费者也不会触发分区分配逻辑。

内容的提问来源于stack exchange，提问作者JeyJ