【Kafka】kafka动态获取某个topic的partition信息

现在有这样一种场景，系统启动前，预期abc topic创建了一个100个分区，大概用个一段时间，之后可能会动态新增分区数，这就要求生产者在生产数据时，能够动态实时的获取分区数，做到及时有效的哈希生效，让数据进入新增的分区，kafka的jar包里倒是有这么一个api可以做到，不过这种场景本人觉得还不如夜里做一次升级呢。 毕竟在生产数据时每次获取abc topic的分区信息是一个性能损耗，一天生产10

>>阅读原文<<