无法从 Talend 中的 tKafkaInput 获取特定分区数据

问题描述 投票:0回答:1

我们有一个分布在 3 个分区的 Kafka 主题,我需要从一个作业中的分区 1 和另一个作业中的分区 2 获取/读取数据。我尝试在 tKafkaInput 组件的高级设置中使用多个 Kafka 参数,但无法成功从特定分区检索数据。 您能否提供我应该在属性中使用的正确表达式或参数来实现此目的?

我已经提前设置了一些参数但不起作用

apache-kafka etl talend kafka-partition
1个回答
0
投票

无法在消费者配置中指定分区

https://docs.confluence.io/platform/current/installation/configuration/consumer-configs.html

为了在消费者 API 中指定分区程序,需要调用分配 API,我假设 Talend 正在执行订阅 API

© www.soinside.com 2019 - 2024. All rights reserved.