skywalking agent使用kafka数据传输

9月前作者：顺kai 分类：Toy博客阅读(56) 违法举报

这篇具有很好参考价值的文章主要介绍了skywalking agent使用kafka数据传输。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

安装Zookeeper

下载相应版本的zookeeper

解压文件

tar -vxzf apache-zookeeper-3.8.0-bin.tar.gz

进入conf目录下，复制zoo_sample.cfg文件，这个是官方提供的配置样例，我们修改复制的文件名称未zoo.cfg。
进入bin目录，启动zookeeper
```
sh zkServer.sh start
```

安装Kafka

下载对应版本的kafka
解压文件
```
tar -zxvf kafka_2.12-3.4.0.tgz
```

修改config/server.properties文件

listeners=PLAINTEXT://:9092
zookeeper.connect=localhost:2181

启动kafka

bin/kafka-server-start.sh -daemon config/server.properties

启动项目

服务层

修改config/application.yml

skywalking agent使用kafka数据传输,kafka,skywalking,java

相关参数根据kafka配置来。

启动sykwalking

bin/startup.sh

检查kafka连接状态

./kafka-topics.sh --bootstrap-server localhost:9092 --list

skywalking agent使用kafka数据传输,kafka,skywalking,java

相关的Topic已经成功创建则表示服务端启动成功。

探针层

将 optional-reporter-plugins目录下kafka-reporter-plugin-8.8.0.jar移动到plugins下。
修改agent.conf文件

skywalking agent使用kafka数据传输,kafka,skywalking,java

重新启动应用。
检查消息发送与消费

./kafka-consumer-groups.sh --describe --bootstrap-server 127.0.0.1:9092 --group skywalking-consumer

skywalking agent使用kafka数据传输,kafka,skywalking,java

.0.1:9092 --group skywalking-consumer文章来源地址https://www.toymoban.com/news/detail-555984.html


[外链图片转存中...(img-PxegJD4n-1684142365290)]

如果LOG-END-OFFSET表示消息投递数，如果CURRENT_OFFSET表示当前消费偏移量。

到了这里，关于skywalking agent使用kafka数据传输的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：如若内容造成侵权/违法违规/事实不符，请点击违法举报进行投诉反馈，一经查实，立即删除！

分享到：

领支付宝红包赞助服务器费用

矢量数据无损压缩传输-geobuf（java项目分享）

Hello小伙伴们，太太太久不更文了，研发太忙了没时间搞，技术性的文章肯定要有干货，今天小编就为大家带来干干干货~ 有段时间在朋友圈看见有朋友分享了他们的产品，其中有几个字眼让我影响深刻“集成了GeoBuf的功能”，让我不禁想探索探索GeoBuf是个啥东东，搜集了有关

2023年04月12日
浏览(47)
使用Sqoop的并行处理：扩展数据传输

使用Sqoop的并行处理是在大数据环境中高效传输数据的关键。它可以显著减少数据传输的时间，并充分利用集群资源。本文将深入探讨Sqoop的并行处理能力，提供详细的示例代码，以帮助大家更全面地了解和应用这一技术。在开始介绍Sqoop的并行处理技术之前，首先了解一下为

2024年01月19日
浏览(33)
使用Socket技术进行数据传输、传输文件；浏览器访问Socket服务器

利用通信线路和通信设备，将地理位置不同的、功能独立的多台计算机互连起来，以功能完善的网络软件来实现资源共享和信息传递，就构成了计算机网络系统 IP地址和端口通过IP地址，区分不同的计算机每一台电脑在一个网络上拥有一个独属于自己的IP地址，用于区别其他

2024年02月07日
浏览(52)
java基于物联网的医疗数据采集传输系统(ssm)

本系统（程序+源码）带文档lw万字以上文末可领取本课题的JAVA源码参考选题背景：随着科技的不断进步，物联网（Internet of Things, IoT）技术已经渗透到医疗健康领域，成为推动现代医疗服务发展的重要力量。传统的医疗数据采集方式多依赖于手工记录和定期体检，这种方

2024年03月15日
浏览(40)
实现一款高可用的 TCP 数据传输服务器（Java版）

首先netty是一款高性能、封装性良好且灵活、基于NIO(真·非阻塞IO)的开源框架。可以用来手写web服务器、TCP服务器等，支持的协议丰富，如：常用的HTTP/HTTPS/WEBSOCKET，并且提供的大量的方法，十分灵活，可以根据自己的需求量身DIV一款服务器。用netty编写TCP的服务器/客户端

2024年02月11日
浏览(40)
C# 使用FTP上传文件、下载文件，实现数据传输

上传文件的方法调用：下载文件方法：

2024年02月14日
浏览(44)
skywalking agent监控java服务

一、前言 skywalking agent可以监控的服务类型有多种，python、go、java、nodejs服务等都可以监控，现在通过java服务来演示skywalking agent的使用，并且是使用容器的方式实现二、部署skywalking agent监控需要注意，skywalking agent服务也是需要使用java服务的，所以需要使用跟java服务对应的

2024年02月11日
浏览(41)
命令行工具-cURL（用于使用URL传输数据）

使用 Postman 进行接口测试，如下图。在 Postman 的代码段里，可以转换你需要的不同语言的代码，其中就可以转换 cURL 代码。将此代码复制到命令行里执行，可以执行成功，请求结果和在 Postman 里执行的结果一样。 cURL 在命令行或脚本中用于传输数据。 cURL 是一个利用

2024年02月15日
浏览(42)
Vue面试题：如何使用事件总线进行组件间数据传输？

问题：假设你正在为一个大型企业级Vue应用程序编写代码，并且需要在多个组件之间传递数据。其中一个组件需要从另一个组件中获取数据，但是这个组件可能还没有加载完成。在这种情况下，你会采取什么措施来确保数据的可靠传输？请提供代码示例来解释你的解决方案。

2023年04月09日
浏览(36)
Python-pyqt不同窗口数据传输【使用静态函数】

在编写pyqt 页面时有时候需要不同页面进行数据传输。本文讲解静态函数方法。直接看示例。输入数据界面接收数据界面在输入数据界面输入值在接收数据界面点击接收，可以发现数据从一个界面传到另一个界面了。 1、将函数变成静态函数方法 @staticmethod 2、其它窗口通

2024年02月11日
浏览(34)