Kafka（二）- Kafka集群部署
Kafka（二）- Kafka集群部署
在Windows安装运行Kafka
一、安装JAVA JDK1、下载安装包http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html注意：根据32/64位操作系统下载对应的安装包2、添加系统变量：JAVA_HOME=C:\Pro
【Flink 实战系列】如何给 Flink 任务设置合理的并行度?
最近看到很多朋友都在问这个问题，当我在开发 Flink 实时计算任务的时候，如何给每个算子设置合理的并行度呢？如果设置多了可能会出现资源浪费的情况，如果设置少了任务可能会出现反压，所以给 Flink 任务设置一个合理的并行度就显得尤为重要，那今天就针对这个问题做一个详细的分析。一个 Flink 任务
Kafka安装部署（3.0.0）
Kafka安装部署（3.0.0）
【应用】SpringBoot 整合 Kafka
SpringBoot 整合消息中间件 Kafka 的基本使用
Docker安装kafka简单步骤
docker安装kafka
Redis Stream适配SpringBoot实现消息队列
众所周知redis数据结构中的list的lpush与rpop可以用于常规消息队列，从集合的最左端写入，最右端弹出消费。并且支持多个生产者与多个消费者并发拿数据，数据只能由一个消费者拿到。但这个方案并不能保证消费者消费消息后是否成功处理的问题（服务挂掉或处理异常等），机制属于点对点模式不能做广播模式（
Kafka多生产者消费者自动配置
自动注册多生产者、多消费者Kafka实例
Java代码实现kafka的消息生产与消费
生产者发送消息到我们的topic分区上，需要等待我们kafka返回的ack，如果没有返回就会进入3s的阻塞，retry3次——>抛出异常（这里面我们可以将信息记录到文件日志中）生产者并不是直接把消息推送给kafka的——>利用了消息缓冲的机制，kafka本地线程默认会创建一个缓冲区 ，用来存放发送的
kafka如何保证消息不丢失？半分钟的答案和半个小时的答案有点不一样。
关于Kafka保证消息不丢失的问题，就简单总结到这里，但这其实并不是结束。相反，随着你对Kafka理解得越深，你会发现这个问题会有更多的发散空间。像MQ如何保证消息不丢失？如何不重复消费？如何处理消息积压？等等，这都是一系列非常开放的面试题。对于你是否真正理解了每个MQ产品，是非常好的检验标准。
Kafka 生产者、消费者命令行操作
Kafka 生产者、消费者命令行操作
@KafkaListener 详解及消息消费启停控制
如果不想使用默认的"kafkaListenerContainerFactory"容器工厂，则必须手动创建一个"ConcurrentKafkaListenerContainerFactory"类的实例，并且其bean name 不能叫"kafkaListenerContainerFactory"（不然
Prometheus+Grafana监控部署以kafka监控为例
Prometheus是由SoundCloud开发的开源监控系统，由GO语言编写而成，采用Pull的方式来获取监控信息，并且提供了多维度的数据模型和灵活的查询接口。Prometheus既支持通过静态文件配置监控对象，还支持自动发现机制，能通过Kubernetes、Consl、DNS等多种方式动态获取监
Kafka
Kafka知识点汇总
Docker部署单节点Kafka
Docker安装Kafka单节点
Spring-Kafka 发送消息的两种写法
本文主要是使用 Java 语言中 spring-kafka 依赖 对 Kafka 进行使用。创建项目，先创建一个简单的 Maven 项目，删除无用的包、类之后，使用其作为一个父级项目。
Kafka生产者的一个Bug会导致部分消息一直无法发送
Node-0 准备开始遍历它下面的几个队列中的ProducerBatch，遍历一次 则drainIndex+1,发现遍历了一个队列之后,就装满了这一批次的请求。因为发送一次的请求量是有限的(max.request.size), 所以一次可能只能发几个ProducerBatch. 那么这次发送了之后,
Kafka发送消费消息
3.发送消息把消息发送给broker中的某个topic我们可以直接在命令行中输入内容，将消息发送到Kafka中，每一行会被当做一个独立的消息；使用kafka的发送消息客户端——>发送到指定的kafka服务器地址和topic主题就是日志文件下：主题-标识id分区下的0000.log上面也讲了消息的发送
Kafka图形管理界面Kafka-eagle安装配置详解
Kafka图形管理界面Kafka-eagle安装配置详解
【SpringBoot】整合Kafka集群
【SpringBoot】整合Kafka集群
