星环TDH之kafka笔记

1.kafka开通krb认证之后,需要在消费kafka时候加载配置文件

./kafka-topics.sh –zookeeper 198.28.1.81:2181 –create –topic hs_user_useroperlog –partitions 3 –replication-factor 1

消费卡夫卡并打印出数据[en]Consume kafka and print out the data

./kafka-console-consumer.sh –bootstrap-server 198.28.1.81:9092 –topic hs_user_useroperlog –from-beginning –new-consumer –consumer.config ../config/consumer.properties

需要添加–Consumer er.config。配置,否则将报告错误[en]Need to add– consumer.config.. / config/consumer.properties configuration, otherwise an error will be reported

错误如下:[en]The error is as follows:

2.明确kafka格式问题kafka最终的数据都是统一的数据,最终转换之后的数据如下:

3.Tdhclient目录下kafka目录结构

tdh比较好的是很多配置文件都整理好了,可以直接使用

Original: https://www.cnblogs.com/wang3680/p/15493436.html
Author: TimBlog
Title: 星环TDH之kafka笔记

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/6020/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

最近整理资源【免费获取】:   👉 程序员最新必读书单  | 👏 互联网各方向面试题下载 | ✌️计算机核心资源汇总