我读了很多关于Kafka交易的文章，看了一些视频，我基本上都明白了。然而，对于一些senarios来说，选择正确的事务id的问题对我来说仍然不清楚。
我在一个单独的任务中运行每个消费者/生产者。
对于一个场景，其中我们有一个消费者/输入分区和一个生产者，我理解所有生产者都可以有相同的前缀（比如说我的id）并初始化事务id my-id.topic.partition 这很管用。
但不清楚的是：
我推出了一个新的消费群体。它第一次跳转时，组中的第一个任务将被分配所有分区，直到其他任务也出现并发生重新平衡。在这种情况下，当一个消费有多个分区时，如何选择事务id？
假设由于重新平衡，a被分配了一个新的分区。如何更改正在运行的消费者/生产者的事务id？此任务尚未重新启动，仅分配了一个新分区