搜索内容

包含标签:kafka 的文章
  • Kafka消费流程
    物联网

    Kafka消费流程

    Kafka消费流程 消息是如何被消费者消费掉的。其中最核心的有以下内容。 1、多线程安全问题 2、群组协调 3、分区再均衡 1.多线程安全问题 当多个线程访问某……
    admin 2024-01-21
  • 保证Kafka消息有序性
    5G

    保证Kafka消息有序性

    一、Kafka特性 写入同一个partion分区中的数据是一定有顺序的 kafka中一个消费者消费一个partion的数据,消费者取出数据时,也是有顺序的 二、保证消息Ka……
    admin 2024-01-21
  • 如何选择消息队列?Kafka 与 RabbitMQ
    研发管理

    如何选择消息队列?Kafka 与 RabbitMQ

    在上一期中,我们讨论了使用消息队列的好处。然后,我们回顾了消息队列产品的历史。现在看来,当我们需要在项目中使用消息队列时,Kafka 是首选产品。但是,……
    admin 2024-01-10
  • ELK+kafka+filebeat企业内部日志分析系统搭建
    物联网

    ELK+kafka+filebeat企业内部日志分析系统搭建

    看上面的拓扑图,我们至少准备七台机器进行下面的实验项目。 机器主要作用分布如下: 三台安装elasticsearch来搭建ES集群实现高可用,其他机器就依次安装file……
    admin 2024-01-07
  • 【日志系列】什么是分布式日志系统?
    物联网

    【日志系列】什么是分布式日志系统?

    ✔️什么是分布式日志系统? 现在,很多应用都是集群部署的,一次请求会因为负载均衡而被路由到不同的服务器上面,这就导致一个应用的日志会分散在不同的服……
    admin 2023-12-30
  • Kafka怎么保证消息发送不丢失
    研发管理

    Kafka怎么保证消息发送不丢失

    前言 Kafka发送消息是异步发送的,所以我们不知道消息是否发送成功,所以会可能造成消息丢失。而且Kafka架构是由生产者-服务器端-消费者三种组成部分构成……
    admin 2023-12-25
  • flink1.12.4消费kafka 报错 The coordinator is not available
    5G

    flink1.12.4消费kafka 报错 The coordinator is not available

    报错 You should retry committing the latest consumed offsets. Caused by: org.apache.kafka.common.errors.CoordinatorNotAvailableException: The coor……
    admin 2023-12-15
  • ELK+filebeat+kafka
    研发管理

    ELK+filebeat+kafka

    nohup ./filebeat -e -c filebeat.yml > filebeat.out & tail -f filebeat.out cd /etc/logstash/conf.d vim kafka.conf input { kafka { ……
    admin 2023-12-07
  • 在服务器导出kafka topic数据
    物联网

    在服务器导出kafka topic数据

            使用Kafka自带的工具:Kafka提供了一个命令行工具kafka-console-consumer,可以用来消费指定Topic的数据并将其打印到控制台。         1.打印到控制……
    admin 2023-11-19
  • Kafka GUI+实时监控——Kafka Assistant
    云计算

    Kafka GUI+实时监控——Kafka Assistant

    Kafka GUI+实时监控——Kafka Assistant 想要查看Topic里的消息却找不到软件,想要查看或更新Broker、Topic配置,想要监控Broker服务器状态?试试下面的Kafka ……
    admin 2023-11-04