时间戳

首页 > 解决方案 > KSQL 流输出主题

apache-kafka - KSQL 流输出主题

问题描述

嗨，我有一个 Ksql 表（NGINX_TABLE）的左连接 Ksql 流（SEARCHREQUESTDTO）。使用以下 ksql 命令

CREATE STREAM NIGINX_SEARCH_QUERY AS \
  SELECT  *\
  FROM SEARCHREQUESTDTO\
  LEFT JOIN NGINX_TABLE\
    ON SEARCHREQUESTDTO.sessionid = NGINX_TABLE.sessionid;

结果流 NIGINX_SEARCH_QUERY 成功。我也可以在 Ksql 终端中使用 show topic 命令查看 NIGINX_SEARCH_QUERY 主题。

在此处输入图像描述

当我尝试将 kafka 消费者连接到此主题时，消费者无法获取任何数据。

但是显示数据的打印 NIGINX_SEARCH_QUERY 命令正在此主题中发布。

在此处输入图像描述

标签： apache-kafkaksqldb

解决方案

如果PRINT显示输出，则主题确实存在并且有数据。

如果您的消费者没有显示输出，那么这是您的消费者的错误。所以我会把你的问题改写为，我有一个 Kafka 主题，我的消费者没有显示数据。

我会用kafkacat外部检查主题：

      kafkacat -b kafka-broker:9092 -C -K: \
      -f '\nKey (%K bytes): %k\t\nValue (%S bytes): %s\n\Partition: %p\tOffset: %o\n--\n' \
      -t NIGINX_SEARCH_QUERY

推荐阅读