2024-11-19 厉飞雨 阅读(220) 评论(0) 赞(18)

<p>在公司测试环境由于内存不足导致kafka服务自动停止，再次启动时java服务日志存在报错：</p> <pre><code>2024-09-18 10:31:35.727 WARN 23061 --- [consumer-0-C-1] o.a.k.c.NetworkClient : [C...

2024-11-19 厉飞雨 阅读(250) 评论(0) 赞(14)

<p>报错信息:Failed to send messages after 3 tries.</p> <pre><code>[2020-03-30 06:53:28,302] ERROR Error in handling batch of 1 events (kafka.producer.async.ProducerSendTh...

2024-11-19 厉飞雨 阅读(269) 评论(0) 赞(25)

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

2024-11-19 厉飞雨 阅读(366) 评论(0) 赞(19)

<p>项目中kafka异常重启导致输出日志报错如下:</p> <pre><code>[2022-11-04 08:24:31,508] FATAL [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server...

2024-11-19 厉飞雨 阅读(295) 评论(0) 赞(19)

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

2024-11-19 厉飞雨 阅读(384) 评论(0) 赞(17)

<h2>1、简介 {#1简介}</h2> <p>在 Apache Kafka 中传输消息时，客户端和服务器会就使用共同的语法格式达成协议。Apache Kafka 提供了默认的转换器（Converter），如 <code>String</code> 和 <code>Long</code>。同时也...

2024-11-19 厉飞雨 阅读(351) 评论(0) 赞(15)

<h1>如何判断在IDEA中程序正在运行或正在Debug {#如何判断在IDEA中程序正在运行或正在Debug}</h1> <p>给大家分享一个有趣又无用的东西，如何判断在IDEA中程序正在运行或正在Debug</p> <p>在这个之前我们首先需要了解一个类<code>ManagementFactory&l...

2024-11-19 厉飞雨 阅读(257) 评论(0) 赞(32)

<h3>提示代码模板 {#提示代码模板}</h3> <pre><code>ctrl + j </code></pre> <br /> <h3>使用异常或者其他代码将指定代码包起来 {#使用异常或者其他代码将指定代码包起来}</h3> <pre><code...

2024-11-19 厉飞雨 阅读(207) 评论(0) 赞(18)

Java类文件头注释 {#java类文件头注释} ------------------------ ``` /**  *  ${TODO}  *  * @author lijing  * @date ${YEAR}-${MONTH}-${DAY}  */ ``` <br /> 配置同步 {#配置同步} ------------ 通过 `Settings Sy...

2024-11-19 厉飞雨 阅读(322) 评论(0) 赞(17)

<p>记录本人使用的idea插件，本人使用的插件不多，因为过多插件可能会影响电脑性能，而且会形成依赖，降低了无插件编程能力。</p> <h2>CamelCase {#camelcase}</h2> <p>轻松切换不同的变量命名风格，默认快捷键是 <code>Shift + Alt + U</code&...