首页 > 其他分享 >Kafka King 推荐一款漂亮、现代、实用的kafka客户端

Kafka King 推荐一款漂亮、现代、实用的kafka客户端

时间:2024-02-16 14:01:33浏览次数:24  
标签:King 分区 主题 支持 kafka topic Kafka

Kafka King

一个漂亮、现代、实用的kafka客户端,使用python flet、flutter构建。

Github主页:https://github.com/Bronya0/Kafka-King

下载:https://github.com/Bronya0/Kafka-King/releases

功能清单

  • 查看集群节点列表
  • 创建主题(支持批量)、删除主题、支持根据消费者组统计每个topic的消息积压量
  • 支持查看topic的分区的详细信息,并为主题添加额外的分区
  • 支持查看每个分区的消息offset
  • 支持模拟生产者,批量发送消息,是否开启gzip压缩
  • 支持模拟消费者,按照内置的组进行指定size的消费
  • 监控、告警(开发中)
  • 多语言支持(开发中)
  • ……

功能截图

操作topic

主题列表,支持删除主题

支持根据消费者组统计每个topic的消息积压量

image

创建主题(支持批量)

image

查看topic的详细配置

image

自动获取集群broker列表

image

获取broker详细配置

image

模拟生产者消费者

  • 支持模拟生产者,批量发送消息,是否开启gzip压缩
  • 支持模拟消费者,按照内置的组进行指定size的消费

image

分区操作

  • 支持查看topic的分区的详细信息
  • 支持为主题添加额外的分区
  • 支持查看每个分区的消息offset

image

标签:King,分区,主题,支持,kafka,topic,Kafka
From: https://www.cnblogs.com/bronya0/p/18017091

相关文章

  • 【XV6】 networking
    代码:https://github.com/JasenChao/xv6-labs.gitE1000网络设备驱动题目已经在kernel/e1000.c中给出了E1000的初始化函数和发送接收函数,要求完善发送和接收的功能。其他相关的代码,上层的网络协议在kernel/net.c和kernel/net.h中。PCI总线上搜索网卡的代码在kernel/pci.c中://t......
  • JAVA并发之PriorityBlockingQueue
    PriorityBlockingQueue(优先阻塞队列)是Java并发包java.util.concurrent下面的一个工具类,它除了具有阻塞队列的功能外还具有以下特点:对队列中的元素进行排序,如果未指定比较器,插入队列的元素必须实现Comparable接口内部基于数组实现的最小二叉堆算法队列的长度是可扩展的(类似Ar......
  • Kafka 生产者
    1.生产者消息发送流程1.发送原理在消息发送的过程中,涉及到了两个线程——main线程和Sender线程。在main线程中创建了一个双端队列RecordAccumulator。main线程将消息发送给RecordAccumulator,Sender线程不断从RecordAccumulator中拉取消息发送到KafkaBroker。2.生......
  • 【Java 并发】【队列应用】【一】ArrayBlockingQueue 的使用-Logback异步日志打印
    1 前言看了那么多Java提供的队列工具,那么我们这节开始看看哪些地方用到了这些队列哈。这一节我们讲解logback异步日志打印中ArrayBlockingQueue的使用。2  异步日志打印模型概述在高并发、高流量并且响应时间要求比较小的系统中同步打印日志已经满足不了需求了,这是因为......
  • 10分钟3个步骤集成使用SkyWalking
    随着业务发展壮大,微服务越来越多,调用链路越来越复杂,需要快速建立链路跟踪系统,以及建立系统的可观测性,以便快速了解系统的整体运行情况。此时就非常推荐SkyWalking了,SkyWalking不仅仅是一款链路跟踪工具,还可以作为一个系统监控工具,还具有告警功能。使用简便、上手又快。真可谓快、......
  • Kafka 命令行操作
    1.Topic(主题)命令行操作1.查看Topic所有命令bin/kafka-topics.sh以下展示为最常使用的参数描述--bootstrap-server<String:servertoconnectto>连接的KafkaBroker主机名称和端口号--topic<String:topic>操作的topic名称--create创建Topic(主题)......
  • 【Java 并发】【十】【JUC数据结构】【十】PriorityBlockingQueue 原理
    1 前言这节我们继续看看另一个队列 PriorityBlockingQueue,优先级的哈。2 PriorityBlockingQueue介绍PriorityBlockingQueue是带优先级的无界阻塞队列,每次出队都返回优先级最高或者最低的元素。其内部是使用平衡二叉树堆实现的,所以直接遍历队列元素不保证有序。默认使......
  • Kafka 3.6.1 集群安装与部署
    1.集群规划hadoop02(192.168.58.130)hadoop03(192.168.58.131)hadoop04(192.168.58.132)zookeeperzookeeperzookeeperkafkakafkakafka2.集群部署1.下载kafka二进制包https://kafka.apache.org/downloads2.解压mkdir/usr/kafkatar-zxvf/home/kafka_2......
  • [Violation ] Added non-passive event listener to ascroll- blocking ‘mousewheel
    [Violation]Addednon-passiveeventlistenertoascroll-blocking'mousewheel’eventConsidermarkingeventhandleras’passive’tomakethepagemoreresponsive.--控制台报错解决方法这个错误翻译过来的的意思就是:[违规]在ascroll中添加了非被动事件侦听器-阻......
  • Flink CDC实时同步PG数据库到Kafka
    一、安装规划操作系统服务器IP主机名硬件配置CentOS7.6192.168.80.131hadoop01内存:2GB,CPU:2核,硬盘:100GBCentOS7.6192.168.80.132hadoop02内存:2GB,CPU:2核,硬盘:100GBCentOS7.6192.168.80.133hadoop03内存:2GB,CPU:2核,硬盘:100GB......