搜索结果
查询Tags标签： consumer，共有 108条记录-
如何获取 Kafka 的消费者详情？ —— 从 Scala 到 Java 的切换
目标及实现 实现如同 bin/kafka-consumer-group.sh –describe –bootstrap-server localhost:9092 –group CONSUMER_GROUP_ID的效果： [root@node2 kafka_2.12-1.0.0]# bin/kafka-consumer-groups.sh --describe --bootstrap-server localhost:9092 --group CONSUMER_GR…
2021/9/7 17:07:56 人评论 次浏览 -
Kafka的工作原理及过程
一、Broker启动当每个 broker 启动时，会在 ZooKeeper 中的 /brokers/ids 路径下创建⼀个节点来注册⾃⼰，节点 ID 为配置⽂件中的 broker.id 参数，后注册的 broker 会报 NodeExists 的错。如果不指定 broker.id 或者指定成 -1，节点 ID 会从 reserved.broker.max.id 这个…
2021/8/27 6:09:12 人评论 次浏览 -
Kafka的工作原理及过程
一、Broker启动当每个 broker 启动时，会在 ZooKeeper 中的 /brokers/ids 路径下创建⼀个节点来注册⾃⼰，节点 ID 为配置⽂件中的 broker.id 参数，后注册的 broker 会报 NodeExists 的错。如果不指定 broker.id 或者指定成 -1，节点 ID 会从 reserved.broker.max.id 这个…
2021/8/27 6:09:12 人评论 次浏览 -
Python简单使用kafka
在Windows上安装kafka可以参考： https://blog.csdn.net/weixin_38004638/article/details/91893910 简介 Kafka是分布式流处理系统（RabbitMQ仅仅只是消息队列），是一个分布式、分区的、多副本的、多订阅者，基于Zookeeper协调的分布式日志系统。kafka的吞吐量是很高的，…
2021/8/10 1:06:04 人评论 次浏览 -
Python简单使用kafka
在Windows上安装kafka可以参考： https://blog.csdn.net/weixin_38004638/article/details/91893910 简介 Kafka是分布式流处理系统（RabbitMQ仅仅只是消息队列），是一个分布式、分区的、多副本的、多订阅者，基于Zookeeper协调的分布式日志系统。kafka的吞吐量是很高的，…
2021/8/10 1:06:04 人评论 次浏览 -
supplier、consumer、funtion、predicate接口的Lambda操作
Lambda表示的操作 /*小括号内是形参，有点占位符的感觉，不进行赋值操作*/@Testpublic void supplierTest() {int[] arr = {176, 34, 22, 544, 23};Integer integer = arrayMax(() -> {int i = arr[0];for(int a:arr){if (a>i)i=a;}return i;});System.out.println(…
2021/8/6 23:09:41 人评论 次浏览 -
supplier、consumer、funtion、predicate接口的Lambda操作
Lambda表示的操作 /*小括号内是形参，有点占位符的感觉，不进行赋值操作*/@Testpublic void supplierTest() {int[] arr = {176, 34, 22, 544, 23};Integer integer = arrayMax(() -> {int i = arr[0];for(int a:arr){if (a>i)i=a;}return i;});System.out.println(…
2021/8/6 23:09:41 人评论 次浏览 -
kafka教程
1.kafka 系统架构1.1 broker kafka 集群包含一个或多个服务器，服务器节点称为 broker。 1.2 Tpoic 每条发布到 kafka 集群的消息都有一个类别，这个类别称为 Topic。类似于数据的表名。物理上不同的 Topic 的消息分开存储。逻辑上一个 Topic 的消息虽然保存于一个或多个 …
2021/8/1 23:08:28 人评论 次浏览 -
kafka教程
1.kafka 系统架构1.1 broker kafka 集群包含一个或多个服务器，服务器节点称为 broker。 1.2 Tpoic 每条发布到 kafka 集群的消息都有一个类别，这个类别称为 Topic。类似于数据的表名。物理上不同的 Topic 的消息分开存储。逻辑上一个 Topic 的消息虽然保存于一个或多个 …
2021/8/1 23:08:28 人评论 次浏览 -
Java之函数编程
前言本系列文章为在《告别996，开启Java高效编程之门》学习过程中的学习笔记和课外资料补充，希望可以方便自己和其他需要的同学查阅。Lambda表达式简介①Java8引入的函数式编程风格；②可以理解为一种匿名函数的代替；③通过行为参数传递代码。Lambda表达式的形式(parame…
2021/7/25 20:36:05 人评论 次浏览 -
Java之函数编程
前言本系列文章为在《告别996，开启Java高效编程之门》学习过程中的学习笔记和课外资料补充，希望可以方便自己和其他需要的同学查阅。Lambda表达式简介①Java8引入的函数式编程风格；②可以理解为一种匿名函数的代替；③通过行为参数传递代码。Lambda表达式的形式(parame…
2021/7/25 20:36:05 人评论 次浏览 -
Java 客户端访问kafka
本文为博主原创，未经允许不得转载：1. 引入maven依赖<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.4.1</version></dependency> 2. kafka 消息生产者发送消息…
2021/7/17 20:07:55 人评论 次浏览 -
Java 客户端访问kafka
本文为博主原创，未经允许不得转载：1. 引入maven依赖<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.4.1</version></dependency> 2. kafka 消息生产者发送消息…
2021/7/17 20:07:55 人评论 次浏览 -
Java工程师的进阶之路 Kafka篇
1. Kafka 诞生背景 Kafka 是最初由 Linkedin 公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于 zookeeper 协调的分布式消息系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景：比如基于 hadoop 的批处理系统、低延迟的实时…
2021/7/9 1:06:29 人评论 次浏览 -
【消息中间件JMS java message service】RocketMQ
基础内容 角色 nameserver 注册中心。可以部署多个实现高可用。所有broker会向nameserver上报，但nameserver之间不互相通报。所有数据放在内存中（可配置成持久化，但没有必要） broker 实例 // 启动mq broker(向指定中心注册） ./mqbroker -n localhost:9876启动的时候，…
2021/7/4 1:21:29 人评论 次浏览
