我有这样一种情况——我有两个java应用程序（假设a1和a2）运行在同一个kafka消费者组（假设g1）上，在不同的主题上（假设t1和t2），只有一个分区（假设p1）。a1使用来自t1的消息并产生到t2的消息。a2使用来自t2的消息并进行一些处理。在这种情况下，a1是否可以为a2保留或创建阻塞，以便a1保持空闲，不做任何事情或不使用任何消息？当使用不同的组但使用相同的组g1时，我收到a2消耗的消息，一点运气都没有。