我尝试使用pentaho Kettle 8的新Kafka消费者步骤,但我无法加载任何数据。我用的时候总是像看书一样,但是看不到任何数据。
有关于如何读取数据的教程或示例吗?我看到官方文档不是很有用,解释得不好,而且我在网上没有找到任何示例。
提前谢谢您,
最佳答案
我有一个工作转换和子转换,我们所做的更改是,
在卡卡变换中,
1.我们在连接时使用直接引导服务器。 2.我们添加了消费者组“cons1” 3. 将选项选项卡上的 auto.offset.reset 更改为“最早”。
在子转换中。
在“从流中获取记录”步骤中,我们提供了以下字段
字段名称类型
关键无
消息无
主题无
分区 无
偏移量无
时间戳 时间戳
卡夫卡版本:kafka_2.11-1.1.0
我上传了一个有效的示例 .ktr https://drive.google.com/file/d/1mr1ZYU_A0uAedRdgRs2oDF6HubOO4UPx/view?usp=sharing
关于apache-kafka - 如何在pentaho 8中使用Kafka消费者?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47867676/