51工具盒子
kafka消费者发送消息失败
报错信息: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...
Github
Kafka 2.12-2.5.0部署文档
#### 什么是Kafka 在流式计算中，Kafka一般用来缓存数据，Storm通过消费Kafka的数据进行计算。 Apache Kafka是一个开源消息系统，由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。 Kafka最初是由LinkedIn公司开发，并于 2011年初开源。2012年10月从Apache Incubator毕业。该项目的目标是为...
kafka重启后提示/brokers/ids/1已被注册问题解决
项目中kafka异常重启导致输出日志报错如下: [2022-11-04 08:24:31,508] FATAL [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer) java.lang.RuntimeEx...
测试环境kafka服务异常重启后无法使用
在公司测试环境由于内存不足导致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（序列化器）
1、简介 {#1简介} ----------- 在 Apache Kafka 中传输消息时，客户端和服务器会就使用共同的语法格式达成协议。Apache Kafka 提供了默认的转换器（Converter），如 `String` 和 `Long`。同时也支持针对特定用例的自定义序列化器 （Serializer）。 2、Apache Kafka 中的 Serializer {#...
管理 Kafka 消费者组
1、简介 {#1简介} ----------- 消费者组允许多个消费者从同一 Topic 消费数据，有助于创建更具可扩展性的 Kafka 应用。 本文将带你了解消费者组以及它们如何在其消费者之间重新平衡分区（Rebalance Partition）。 2、消费者组是什么？ {#2消费者组是什么} ---------------------- 消费者组是一组与一个或多个 ...
BFG Repo-Cleaner，一行命令替换、删除、修改git提交记录
工具介绍 {#工具介绍} ------------ BFG Repo-Cleaner是一个使用scal语言编写的开源工具，它提供更快更简单的方式操作git提交记录，它是`git filter-repo`一个有效替代工具，能够更轻松的完成任务。 你可以用它来做什么？ {#你可以用它来做什么} ----------------------- 1. 可以删除提交记录中的不再使用...
git多用户配置
1.删除GIT全局配置 {#1-删除GIT全局配置} -------------------------- 查看是否进行过全局配置 |-----------|------------------------------------| | ``` 1 ``` | ``` git config --global --list ``` | 如果配置过，会出现 |-------...
Git笔记
Git入门到精通 {#git入门到精通} ==================== Git概述 {#git概述} -------------- > Git是一个免费开源的分布式版本控制系统 ### 工作原理 {#工作原理} 
如何快速检索好用的GitHub项目？
**GitHub** 一、基础检索 {#一-基础检索} ================ 1、检索名称 {#1-检索名称} ---------------- 搜索项目标题关键字 in:name openwrt  2、检索备注 {#2-检索备注} ---...
