您的位置:首页技术文章关键词: Kafka
文章列表

  • Java实现Kafka生产者消费者代码实例
  • Kafka的结构与RabbitMQ类似,消息生产者向Kafka服务器发送消息,Kafka接收消息后,再投递给消费者。生产者的消费会被发送到Topic中,Topic中保存着各类数据,每一条数据都使用键、值进行保存。每一个Topic中都包含一个或多个物理分区(Partition),分区维护着消息的内容和...
  • 日期:2022-09-02
  • 浏览:82
  • 标签: Java

  • Java kafka如何实现自定义分区类和拦截器
  • 生产者发送到对应的分区有以下几种方式:(1)指定了patition,则直接使用;(可以查阅对应的java api, 有多种参数)(2)未指定patition但指定key,通过对key的value进行hash出一个patition;(3)patition和key都未指定,使用轮询选出一个patitio...
  • 日期:2022-08-31
  • 浏览:131
  • 标签: Java

  • 利用扩展的方式在PHP中使用Kafka的教程分享
  • 这篇文章主要为大家详细介绍了如何利用扩展的方式实现在PHP中使用Kafka,具体包括扩展安装和这种方式的基本操作,感兴趣的小伙伴可以跟随小编一起学习一下
  • 日期:2022-06-14
  • 浏览:94
  • 标签: PHP


  • Apache Kafka 分区重分配的实现原理解析
  • 这篇文章主要介绍了Apache Kafka 分区重分配的实现原理,本文结合 2.0.0 版本的 Kafka 源码,详细介绍了 Kafka 分区副本重分配的流程和逻辑,需要的朋友可以参考下
  • 日期:2023-03-07
  • 浏览:409
  • 标签: Linux Apache



  • 使用spring boot 整合kafka,延迟启动消费者
  • spring boot 整合kafka,延迟启动消费者spring boot整合kafka的时候一般使用@KafkaListener来设置消费者,但是这种方式在spring启动的时候就会立即开启消费者。如果有需要根据配置信息延迟开启指定的消费者就不能使用这种方式。参考了类:KafkaListener...
  • 日期:2023-02-18
  • 浏览:266
  • 标签: Spring

  • Zabbix对Kafka topic积压数据监控的解决方案
  • 这篇文章主要介绍了Zabbix对Kafka topic积压数据监控的解决方案,它与Apache Storm和Spark非常好地集成,用于实时流式数据分析,需要的朋友跟随小编一起看看吧
  • 日期:2023-04-06
  • 浏览:648
  • 标签: Zabbix

  • Spring boot 整合KAFKA消息队列的示例
  • 这里使用 spring-kafka 依赖和 KafkaTemplate 对象来操作 Kafka 服务。一、添加依赖和添加配置项1.1、在 Pom 文件中添加依赖<dependency> <groupId>org.springframework.kafka</group...
  • 日期:2023-08-08
  • 浏览:287
  • 标签: Spring