Kafka搭建系统实时监控平台，到达时间阈值或者数量限制后并实现Redis日批量入库

╰+哭是因爲堅強的太久メ 2023-06-15 11:29 10阅读 0赞

### 代码： ###

**1.生产者**

import org.apache.kafka.clients.producer.Callback;
    import org.apache.kafka.clients.producer.KafkaProducer;
    import org.apache.kafka.clients.producer.ProducerRecord;
    import org.apache.kafka.clients.producer.RecordMetadata;
    
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.JSONObject;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.Properties;
    import java.util.Random;
    import java.util.concurrent.ExecutionException;
    
    /**
     * kafka线程生产消费数据
     * @author linhaiy
     * @date 2019.07.05
     */
    public class Producer extends Thread {
        private final KafkaProducer<Integer, String> producer;
        private final String topic;
        private final Boolean isAsync;
    
        /**
         * 生产者构造函数，初始化配置信息
         * @param topic
         * @param isAsync
         */
        public Producer(String topic, Boolean isAsync) {
            Properties props = new Properties();

发表评论取消回复

表情：

评论列表（有 0 条评论，10人围观）

还没有评论，来说两句吧...

相关阅读

相关 java——spring boot集成kafka——搭建线上监控平台

![baad96bb2852aa460b0717ba21ed4d51.png][] ![56b4f24ebfb6d5ec8bc26efa40615ef5.png][] [

一时失言乱红尘/ 2023年09月30日 21:54/ 0 赞/ 5 阅读

相关 Kafka搭建系统实时监控平台，到达时间阈值或者数量限制后并实现Redis日批量入库

代码： 1.生产者 import org.apache.kafka.clients.producer.Callback; import org.apac

╰+哭是因爲堅強的太久メ/ 2023年06月15日 11:29/ 0 赞/ 11 阅读

相关 zabbix分布式系统监控----zabbix监控平台搭建监控端(2)

文章目录一、zabbix的工作流程二、zabbix实验环境三、zabbix的环境搭建 3.1 在serv

分手后的思念是犯贱/ 2023年05月29日 05:21/ 0 赞/ 186 阅读

相关 Nagios 监控平台搭建

Nagios 介绍 Nagios 是一款开源的免费网络监视工具，能有效监控 Windows、Linux 和 Unix 的主机状态，交换机路由器等网络设置，打印机等。在

短命女/ 2022年12月24日 00:44/ 0 赞/ 259 阅读

相关 Cacti 监控平台搭建

Cacti 介绍作为一名 Linux SA，日常最重要的就是保证网站正常稳定的运行，我们需要实时监控网站、服务器的运行状态，这时需要借助开源软件（cacti、na

柔情只为你懂/ 2022年12月24日 00:43/ 0 赞/ 238 阅读

相关 flume-ng+Kafka+Storm+HDFS 实时系统搭建

转载：http://blog.csdn.net/weijonathan/article/details/18301321 和 http://www.51studyit.com/

逃离我推掉我的手/ 2022年08月03日 15:40/ 0 赞/ 171 阅读

相关 elastic-job监控平台搭建

1. 首先是上github下载elastic-job的源码，地址如下（下载前要注意源码需要和你使用的elastic-job版本一致,记得切换分支）： [https

今天药忘吃喽~/ 2022年06月07日 14:08/ 0 赞/ 268 阅读

相关 flume-ng+Kafka+Storm+HDFS 实时系统搭建

今天搭建了一下storm流处理系统,整个搭建的流程都是参考以下地址:http://www.cnblogs.com/web-v/articles/6510090.html 文章

布满荆棘的人生/ 2022年06月06日 06:15/ 0 赞/ 147 阅读

相关 Pinpoint APM监控平台搭建

1 系统环境 Ubuntu 16.04 LTS hbase-1.2.6-bin.tar.gz([http://hbase.apache.org/][http_

古城微笑少年丶/ 2022年05月26日 11:10/ 0 赞/ 434 阅读

相关系统对文件监控的数量已经到达限制数量

解决方法：修改系统监控文件数量（Ubuntu系统，其他系统应该也差不多） sudo gedit /etc/sysctl.conf 添加一行在最下面 f

小灰灰/ 2022年03月10日 20:11/ 0 赞/ 233 阅读