apache-kafka - 如何在pentaho 8中使用Kafka消费者?

标签 apache-kafka pentaho kettle consumer

我尝试使用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/

相关文章:

mongodb - 如何在Kettle中过滤Mongodb INPUT时传递变量

migration - Kettle是一个好的数据迁移解决方案吗?

java - 在服务器上运行时设置类的参数

apache-kafka - Kafka代替Zookeeper进行集群管理

transformation - 如何在 Pentaho Spoon 中拆分列的值?

java - Apache 卡夫卡 (KStreams) : How to subscribe to multiple topics?

mysql - Pentaho 错误 - ConnectionServiceImpl.ERROR_0009 - 连接到数据库 [null] 失败

sql-server - 尝试从 Pentaho 写入十进制 (38,0) 类型的 Sql Server 列时出现溢出异常

apache-kafka - Kafka 消费者不是从最新消息开始

apache-spark - 动态更新 spark kafka 消费者的主题列表