ksql流输出主题

tcbh2hod 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(365)

嗨，我留下了一个带有ksql表（nginx\u表）的join ksql流（searchrequestdto）。使用以下ksql命令

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

结果流niginx\u search\u查询成功。我还可以在ksql终端中使用showtopic命令查看niginx\u search\u查询主题。

当我尝试将kafka消费者连接到此主题时，消费者无法获取任何数据。
但print niginx\u search\u query命令显示此主题中正在发布的数据。

apache-kafka ksqldb

来源：https://stackoverflow.com/questions/52186813/ksql-stream-output-topic

1条答案

按热度按时间

v64noz0r1#

如果 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

赞(0）回复(0）举报 2021-06-06

我来回答

ksql流输出主题

1条答案

相关问题

热门标签

最新问答