graylog+kafka+zookeeper（单机测试及源码），graylog收集kafka（脚本创建发布订阅方式）存储的消息（四）
graylog+kafka+zookeeper（单机测试及源码），graylog收集kafka（脚本创建发布订阅方式）存储的消息（四）
- 问题背景
- graylog+kafka+zookeeper（单机测试及源码），graylog组件部署，查找问题分析（一）
- graylog+kafka+zookeeper（单机测试及源码），kafka+zookeeper组件部署（二）
- graylog+kafka+zookeeper（单机测试及源码），graylog测试用例及源码（三）
- graylog+kafka+zookeeper（单机测试及源码），graylog收集kafka（脚本创建发布订阅方式）存储的消息（四）
- graylog+kafka+zookeeper（单机测试及源码），graylog设置URL报警方式（五）
- graylog+kafka+zookeeper（单机测试及源码），graylog+filebeat+sidecars收集log日志（六）
- graylog+kafka+zookeeper（单机测试及源码），微服务日志查询使用（七）
- graylog+kafka+zookeeper（单机测试及源码），仪表板Dashboards创建及使用（八）
- graylog+kafka+zookeeper（单机测试及源码），indices索引和streams流创建及使用，日志定期删除功能（九）
- graylog收集kafka消息
- 问题总结
- Lyric： 满满的被收割
问题背景
前三个篇章介绍了graylog+kafka+zookeeper的单机安装部署以及使用，这个篇章做一个简单的 graylog 收集 kafka 存储的消息，目前直接第二篇kafka的发布者和订阅者。
graylog+kafka+zookeeper（单机测试及源码），graylog组件部署，查找问题分析（一）
graylog+kafka+zookeeper（单机测试及源码），kafka+zookeeper组件部署（二）
graylog+kafka+zookeeper（单机测试及源码），graylog测试用例及源码（三）
graylog+kafka+zookeeper（单机测试及源码），graylog收集kafka（脚本创建发布订阅方式）存储的消息（四）
graylog+kafka+zookeeper（单机测试及源码），graylog设置URL报警方式（五）
graylog+kafka+zookeeper（单机测试及源码），graylog+filebeat+sidecars收集log日志（六）
graylog+kafka+zookeeper（单机测试及源码），微服务日志查询使用（七）
graylog+kafka+zookeeper（单机测试及源码），仪表板Dashboards创建及使用（八）
graylog+kafka+zookeeper（单机测试及源码），indices索引和streams流创建及使用，日志定期删除功能（九）
graylog收集kafka消息
1 开启kafka的input输入
2 修改 kafka 和 zookeeper 的 IP 地址，点击确定
3 进入 /opt/modules/kafka/bin，启动kafka
./kafka-server-start.sh -daemon ../config/server.properties
jps
4 创建 kafka 的 topic，名字为 test
./kafka-topics.sh --create --zookeeper 10.10.195.199:2181 --replication-factor 1 --partitions 1 --topic test
查看topic列表
./kafka-topics.sh --list --zookeeper 10.10.195.199:2181
5 创建发布者
./kafka-console-producer.sh --broker-list 10.10.195.199:9092 --topic test
6 Xshell再开一个窗口，创建订阅者
./kafka-console-consumer.sh --zookeeper 10.10.195.199:2181 --from-beginning --topic test
7 发布者发送消息，订阅者接收消息
8 点击kafkaTest的Show received messages
9 可以看到已经收集到了kafka test topic的消息
问题总结
1 目前使用的是脚本创建发布订阅者的单机测试，下次出一篇项目工程的单机测试用例
作为程序员第 12 篇文章，每次写一句歌词记录一下，看看人生有几首歌的时间，wahahaha …
Lyric： 满满的被收割
graylog+kafka+zookeeper（单机测试及源码），graylog收集kafka（脚本创建发布订阅方式）存储的消息（四）相关推荐
- graylog+kafka+zookeeper(单机测试及源码)，graylog组件部署，查找问题分析(一)
graylog+kafka+zookeeper(单机测试及源码),graylog组件部署,查找问题分析(一) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylog ...
- graylog+kafka+zookeeper（单机测试及源码），kafka+zookeeper组件部署（二）
graylog+kafka+zookeeper(单机测试及源码),kafka+zookeeper组件部署(二) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylo ...
- graylog+kafka+zookeeper（单机测试及源码），graylog设置URL报警方式（五）
graylog+kafka+zookeeper(单机测试及源码),graylog设置URL报警方式(五) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylog组件 ...
- graylog+kafka+zookeeper（单机测试及源码），微服务日志查询使用（七）
graylog+kafka+zookeeper(单机测试及源码),微服务日志查询使用(七) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylog组件部署,查找问题 ...
- graylog+kafka+zookeeper（单机测试及源码），graylog测试用例及源码（三）
graylog+kafka+zookeeper(单机测试及源码),graylog测试用例及源码(三) 问题背景 graylog+kafka+zookeeper(单机测试及源码),graylog组件部署 ...
- zookeeper -- Mac 上 Intellij IDEA 配置 zookeeper(3.5.8) 源码阅读、运行、调试环境
近期需要整理MIT6.824 中 分布式系统协调服务 zookeeper 的一些知识,想要在Mac 本地搭建一个可以方便运行调试的zookeeper环境,这玩意竟然耗费了一上午的时间,实在是不可忍:当 ...
- 实际测试例子+源码分析的方式解剖MyBatis缓存的概念
前言: 前方高能! 本文内容有点多,通过实际测试例子+源码分析的方式解剖MyBatis缓存的概念,对这方面有兴趣的小伙伴请继续看下去~ 欢迎工作一到五年的Java工程师朋友们加入Java架构开发:79 ...
- 【kafka】Kafka中的动态配置源码分析
1.概述 2.源码分析 Broker启动加载动态配置 KafkaServer.startup 启动加载动态配置总流程 2.1 动态配置初始化 config.dynamicConfig.initiali ...
- 【kafka】kafka Producer Metadata概述及源码分析
1.概述 转载:Kafka源码阅读(二):Producer Metadata概述及源码分析 2.Metadata 什么是metadata? metadata指Kafka集群的元数据,包含了Kafka集 ...
最新文章
- 从事安卓开发6年，我都有哪些收获？
- Android Mvp 架构
- how to identify keywords for search on Google Scholar?
- 为什么python的命名不能以数字开头_python变量不能以数字打头
- pandas添加、修改dataframe中index的列名
- 巧用FineReport搭建成本管控监测系统
- Mybaitis框架与Spring整合详解（三）
- Python基于Snap7与PLC建立连接并读写数据
- Linux GCC编译详细
- C语言 车辆出租管理系统
- MySQL5及更高版本的jar包下载（jdbc）及常见问题解决
- 百思不得姐之广告界面(三)
- 键盘修改改器绿化版免安装
- RPC（管理端口的服务）NFS软件 NFS配置文件 简单介绍
- 张驰咨询：快速提高流程效率的5个关键精益生产工具
- React类组件的两种写法
- JAVAEE学习day02
- 【人类高质量层次分析法教程】1分钟实现AHP+矩阵一致性调整
- java sca_用于Java的SCA客户机和实现模型
- C. Anu Has a Function