我们有一个分布在 3 个分区的 Kafka 主题,我需要从一个作业中的分区 1 和另一个作业中的分区 2 获取/读取数据。我尝试在 tKafkaInput 组件的高级设置中使用多个 Kafka 参数,但无法成功从特定分区检索数据。 您能否提供我应该在属性中使用的正确表达式或参数来实现此目的?
无法在消费者配置中指定分区
https://docs.confluence.io/platform/current/installation/configuration/consumer-configs.html
为了在消费者 API 中指定分区程序,需要调用分配 API,我假设 Talend 正在执行订阅 API