Kafka

bridge

累计撰写 108 篇文章
累计创建 37 个标签
累计收到 5 条评论

标签搜索

以下是 Kafka 相关的文章

2022-01-27
九、SpringBoot集成Kafka 一、准备工作1.导入依赖<dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka</artifactId></de
- 2022-01-27
- 1,403 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
八、Kafka 的 Consumer API 1.消费者APIConsumer 消费数据时的可靠性是很容易保证的，因为数据在 Kafka 中是持久化的，故不用担心数据丢失问题。由于 consumer 在消费过程中可能会出现断电宕机等故障，consumer 恢复后，需要从故障前的位置的继续消费，所以 consumer 需要实时记录自己消费到了哪个
- 2022-01-27
- 1,798 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
七、Kafka 的 Producer API 1.消息发送流程Kafka 的 Producer 发送消息采用的是异步发送的方式。在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程，以及一个线程共享变量——RecordAccumulator。main 线程将消息发送给 RecordAccumulator，Sender 线
- 2022-01-27
- 1,858 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
六、Kafka 消费者
- 2022-01-27
- 1,264 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
五、Kafka 生产者 1.分区策略1 ）分区的原因（1）方便在集群中扩展，每个 Partition可以通过调整以适应它所在的机器，而一个 topic又可以有多个 Partition 组成，因此整个集群就可以适应任意大小的数据了；（2）可以提高并发，因为可以以 Partition 为单位读写了。2 ）分区的原则我们
- 2022-01-27
- 1,314 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
四、Kafka工作流程及文件存储机制 1.分区策略1 ）分区的原因（1）方便在集群中扩展，每个 Partition可以通过调整以适应它所在的机器，而一个 topic又可以有多个 Partition 组成，因此整个集群就可以适应任意大小的数据了；（2）可以提高并发，因为可以以 Partition 为单位读写了。2 ）分区的原则我们
- 2022-01-27
- 1,411 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
三、Kafka验证部署测试topic创建和删除创建topic/opt/kafka/bin/kafka-topics.sh --create --zookeeper node01:2181,node02:2181,node03:2181 --topic test-topic --partitions 3 --replica
- 2022-01-27
- 1,328 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
二、Centos7安装部署Kafka集群准备软件软件版本下载地址jdkjdk_8u261下载地址;提取码:500wzookeeeperzookeeper 3.6.1下载地址kafkakafka_2.13-2.5.0下载地址kafka-managerkafka-manager-1.3.3.4下载地址;提取码:nse2安装Jdk解压并将文件移
- 2022-01-27
- 1,425 阅读
- 0 评论
- 0 点赞
- Kafka
2022-01-27
一、Kafka概述 1.1.定义Kafka 是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。1.2.消息队列使用消息队列好处1）解耦允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。2）可恢复性系统的一部分组件失效时，不会影响到整个系统。消息队
- 2022-01-27
- 1,282 阅读
- 0 评论
- 0 点赞
- Kafka