问答 2024-06-01 来自:开发者社区

消息队列Kafka版告警消费客户端主动离开消息队列

消息队列Kafka版告警消费客户端主动离开消息队列

问答 2024-05-31 来自:开发者社区

连接消息队列kafka版客户端偶尔报错NetworkException: The server...

连接消息队列kafka版客户端偶尔报错NetworkException: The server disconnected before a response was received

文章 2024-01-02 来自:开发者社区

Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka

操作步骤Maven依赖核心依赖 kafka-clients<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>1.1.0...

Apache Kafka-初体验Kafka(04)-Java客户端操作Kafka
文章 2023-12-18 来自:开发者社区

python-kafka客户端封装

前言本文对python的kafka包做简单封装,方便kafka初学者使用。包安装:pip install kafka-python封装代码kafka_helper.py#!/usr/bin/env python # -*- coding: utf-8 -*- import json import traceback from kafka import KafkaConsumer, KafkaPr....

文章 2023-12-12 来自:开发者社区

深入浅出分析kafka客户端程序设计 ----- 消费者篇----万字总结(下)

深入浅出分析kafka客户端程序设计 ----- 消费者篇----万字总结(上):https://developer.aliyun.com/article/1393837?spm=a2c6h.24874632.expert-profile.8.6af22f31AcelSW5 消费Rebalance机制当kafka遇到如下四种情况的时候,kafka会触发Rebalance机制:1.  消....

文章 2023-12-12 来自:开发者社区

深入浅出分析kafka客户端程序设计 ----- 消费者篇----万字总结(上)

1.kafka消费者的逻辑配置消费者客户端参数。创建相应的消费者实例。订阅主题。拉取消息并消费;提交消息位移;关闭消费者实例;2 Kafka 的C++ API2.1 RdKafka::Conf见生成者实现文章。2.2 RdKafka::Event见生成者实现文章。2.3 RdKafka::EventCb见生成者实现文章。2.4 RdKafka::TopicPartitionstatic Topi....

文章 2023-12-12 来自:开发者社区

深入浅出分析kafka客户端程序设计 ----- 生产者篇----万字总结(下)

深入浅出分析kafka客户端程序设计 ----- 生产者篇----万字总结(上):https://developer.aliyun.com/article/1393794?spm=a2c6h.24874632.expert-profile.11.6af22f31AcelSW2.6 RdKafka::PartitionerCb一个用于自定义消息分区策略的回调函数 partitioner_cb,它会....

深入浅出分析kafka客户端程序设计 ----- 生产者篇----万字总结(下)
文章 2023-12-12 来自:开发者社区

深入浅出分析kafka客户端程序设计 ----- 生产者篇----万字总结(上)

前面在深入理解kafka中提到的只是理论上的设计原理,本篇讲得是基于c语言的kafka库的程序编写!!!!!首先要编写生产者的代码,得先知道生产者的逻辑在代码上是怎么体现的1.kafka生产者的逻辑怎么理解呢?我们在实例化生产者对象之前的话,肯定是要对一些参数进行配置,比如下面介绍的conf这些那么 配置完参数之后,就是创建生产者实例,那么实例化生产者之后,就是准备生产者生产消息,那么我们在生产....

深入浅出分析kafka客户端程序设计 ----- 生产者篇----万字总结(上)
文章 2023-10-21 来自:开发者社区

Golang 语言中 kafka 客户端库 sarama

介绍Apache Kafka 是一款开源的消息引擎系统。它在项目中的作用主要是削峰填谷和解耦。本文我们只介绍 Apache Kafka 的 Golang 客户端库 Sarama。Sarama 是 MIT 许可的 Apache Kafka 0.8 及更高版本的 Golang 客户端库。如果读者朋友对 Apache Kafka 服务端还不了解,建议先阅读官方文档中的入门部分,本文使用的版本是 Apa....

文章 2023-09-11 来自:开发者社区

图解Kafka消费者客户端分区分配策略

提示:本文可能已过期,请点击原文查看:图解Kafka消费者客户端分区分配策略作者:石臻臻, CSDN博客之星Top5、Kafka Contributor 、nacos Contributor、华为云 MVP ,腾讯云TVP, 滴滴Kafka技术专家 、KnowStreaming PMC, 《Kafka运维与实战宝典》电子书作者。 领取《Kafka运维与实战宝典》PDF请联系石臻臻KnowStre....

图解Kafka消费者客户端分区分配策略

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注