我们已经为连续迁移设置了一个单一的消费者组,多个主题。有一个正在运行的服务,它将一个新的使用者实例连接到每个主题。我们有能力在保持其他主题运行的同时,禁用单个主题的使用者。
有时,我们必须重置特定主题的偏移量,以便重新开始迁移。是否有一种方法可以覆盖禁用所有使用者的必要性?由于偏移量是在每个主题的基础上保存在使用者组中的,我不明白为什么我们必须禁用到所有其他主题的连接。如果这是不可能的,那么使用单个使用者组阅读多个主题有什么好处呢?
示例:
service A -> consumer with group "migration" -> consumes topic
我试着让两个消费者订阅一个EmbeddedKafkaBroker。第一个成功了,第二个失败了。@EmbeddedKafka和@ClassRule brokers都失败了。
@RunWith(SpringRunner.class)
@SpringBootTest
@EmbeddedKafka(topics = { "topic" })
public class AnnotationEmbeddedKafkaTest {
@Autowired
private EmbeddedKafkaBroker broker;
@Test
public voi