51工具盒子

依楼听风雨
笑看云卷云舒,淡观潮起潮落

Github

kafka消费者发送消息失败

kafka消费者发送消息失败

厉飞雨 阅读(10) 评论(0) 赞(3)

报错信息:Failed to send messages after 3 tries. [2020-03-30 06:53:28,302] ERROR Error in handling batch of 1 events (kafka.producer.async.ProducerSendThread) kafka.common.FailedToSendMe...

Kafka 2.12-2.5.0部署文档

Kafka 2.12-2.5.0部署文档

厉飞雨 阅读(8) 评论(0) 赞(3)

#### 什么是Kafka 在流式计算中,Kafka一般用来缓存数据,Storm通过消费Kafka的数据进行计算。 Apache Kafka是一个开源消息系统,由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。 Kafka最初是由LinkedIn公司开发,并于 2011年初开源。2012年10月从Apache Incubator毕业。该项目的目标是为...

测试环境kafka服务异常重启后无法使用

测试环境kafka服务异常重启后无法使用

厉飞雨 阅读(11) 评论(0) 赞(3)

在公司测试环境由于内存不足导致kafka服务自动停止,再次启动时java服务日志存在报错: 2024-09-18 10:31:35.727 WARN 23061 --- [consumer-0-C-1] o.a.k.c.NetworkClient : [Consumer clientId=consumer-ori-datasou...

自定义 Apache Kafka Serializer(序列化器)

自定义 Apache Kafka Serializer(序列化器)

厉飞雨 阅读(10) 评论(0) 赞(3)

1、简介 {#1简介} ----------- 在 Apache Kafka 中传输消息时,客户端和服务器会就使用共同的语法格式达成协议。Apache Kafka 提供了默认的转换器(Converter),如 `String` 和 `Long`。同时也支持针对特定用例的自定义序列化器 (Serializer)。 2、Apache Kafka 中的 Serializer {#...

管理 Kafka 消费者组

管理 Kafka 消费者组

厉飞雨 阅读(14) 评论(0) 赞(4)

1、简介 {#1简介} ----------- 消费者组允许多个消费者从同一 Topic 消费数据,有助于创建更具可扩展性的 Kafka 应用。 本文将带你了解消费者组以及它们如何在其消费者之间重新平衡分区(Rebalance Partition)。 2、消费者组是什么? {#2消费者组是什么} ---------------------- 消费者组是一组与一个或多个 ...

BFG Repo-Cleaner,一行命令替换、删除、修改git提交记录

BFG Repo-Cleaner,一行命令替换、删除、修改git提交记录

厉飞雨 阅读(12) 评论(0) 赞(3)

工具介绍 {#工具介绍} ------------ BFG Repo-Cleaner是一个使用scal语言编写的开源工具,它提供更快更简单的方式操作git提交记录,它是`git filter-repo`一个有效替代工具,能够更轻松的完成任务。 你可以用它来做什么? {#你可以用它来做什么} ----------------------- 1. 可以删除提交记录中的不再使用...

git多用户配置

git多用户配置

厉飞雨 阅读(12) 评论(0) 赞(3)

1.删除GIT全局配置 {#1-删除GIT全局配置} -------------------------- 查看是否进行过全局配置 |-----------|------------------------------------| | ``` 1 ``` | ``` git config --global --list ``` | 如果配置过,会出现 |-------...