学习完生产者，下面自然就是消费者。消费者要学习的内容比生产者要多，本篇主要聚焦于消费者/消费组的基本概念以及客户端的基本开发（包括如何订阅主题和分区、如何消费消息）。 一、消费者和消费组 在学习消费者消费消息之前，需要先了解消费者和消费组的关系。 消费者负责订阅kafka的主题，并且可以从订阅的主题上拉取消息。与其他一些消息中间件不同的是：在kafka的消费理念中还有一层消费组的概念，每个消费者都有一个对应的消费组。当消息发布到主题后，只会被投递给订阅它的每个消费组中的一个消费者。 消费者以组的名义订阅主题，主题有多个分区，消费者组中有多个消费者实例，那么消费者实例和分区之间的对应关系是怎样的...

为了方便对实习生小课题中kafka方便调试，我决定在自己的腾讯云服务器上部署一个单机kafka，其实跟本地windows没啥区别，不过还是做一下记录吧。服务器环境是centod7.3。 第一步-安装JDK 安装jdk1.8或以上版本。由于现在下载jdk都需要先注册，而注册内容令人不适，所以这里贴出一个我的百度云下载地址，方便大家使用，包含了exe和tar两个版本。  链接：https://pan.baidu.com/s/1Yb7s1hFJ2FvqVs1lH6E7WQ    提取码：3chj   具体安装可以参考我之前写过的笔记：  基于virtualbox+centos6.9的服务器搭建 阿里...

环境准备  JDK8自行下载 kafka下载【我自己用的是以前下载的版本，为 kafka_2.11-2.1.0.tgz 这个版本，直接下载解压即可】  KafKA使用 由于是windows环境，解压之后我们的注意点是kafka_2.11-2.1.0\bin\windows目录。  启动ZK 在此目录下打开cmd，执行命令zookeeper-server-start.bat ..\..\config\zookeeper.properties，如下图表示启动成功：  启动KAFKA 依旧在目录下打开cmd，执行命令kafka-server-start.bat ..\..\config\server...

在完成kafka的入门以及基本的操作之后，相信已经对kafka有了基本认识，下面我们一起从kafka的生产者开始，深入学习一下。 一、一个简单的生产者示例 public class KafkaProducerAnalysis { //注1：brokerList可以写多个，中间用逗号隔开 public static final String brokerList = "localhost:9092"; public static final String topic = "topic-demo"; public static Properties init...

一、为什么要学习kafka 目前，kafka的定位是一个分布式流处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而被广泛使用。截止到写本文的时间：2019年08月21号，已经到了2.3版本，kafka也成为后端程序猿或者大数据程序猿不可不学习的一个重要中间件。它又三大特点：  消息系统  市面上有很多的消息中间件，这些消息中间件的主要功能是：系统解耦、冗余存储、流量削峰、缓冲、异步通信、扩展性、可恢复等功能。但是kafka不仅包含这些内容，还提供大多数消息中间件不能实现的：消息顺序性保障和回溯消费等功能。  存储系统  Kafka支持消息的持久化，相比于其他内存存储系统有较...

在开发中可能会遇到多个库的连接，那么一个库就是一个数据源，在程序中如何快速动态地切换数据源呢？本文来探讨一下spring提供的AbstractRoutingDataSource实现方案。 实现 比如我有三个数据源，分别交DATASOURCE_A、DATASOURCE_B、DATASOURCE_C，我假设默认是DATASOURCE_A，此时我需要用B来查询，我理想的效果是： //需要切换数据源 CustomerContextHolder.setCustomerType(CustomerContextHolder.DATASOURCE_B); List<xxx> xxxList = x...

RT，这部门面完之后啥消息都没有，具体面试时间是9.25，面试地点是南京，java，请问大家是不是凉了？？？？

从上午九点等到了接近12.30半吧，终于轮到我面试。面试持续一个多小时，主要就两个问题。   一开始自我介绍，你的项目，里面你认为比较重要的点。spring aop的原理。三次握手说一说。    第一个问题是：有n个硬币，n为偶数，上面有随机的数值，两个人只能从两端轮流取一个硬币。问：全部取完(我理解为每次取都保证这个人赢了)，如何保证其中一个人必胜。   解决思路：一定要注意是偶数，将其下标标出来(0,1,2,.....,n-1)，首先是分别将偶数位和奇数位的数值都加起来。找出大的一方，比如偶数位大，那么我就可以限制对方永远只拿奇数位的硬币。    第二个问题是：借助Iterator中的ne...

听说今年美团的后台开发基本上都满了，但是今天又收到美团点评的笔试通知（上次没做），想问一下，还有必要写么

地点：南京；时间：下午两点；技能：java开发   一面    手写一个你认为最快的排序算法    上来先手撕，我写了一个归并排序，只要不是冒泡之类n^2复杂度的应该就可以了吧。    针对我项目中一个秒杀的细节：redis的预减库存并发的问题   HashMap,HashTable,ConcurrentHashMap区别原理啥的说一说   spring几种注入方式和区别   项目中redis分布式锁的实现原理   JVM哪些区域可能会出现OOM   spring bean的生命周期   redis的淘汰策略    给了一个小的场景，比如有一百万个数据，其中redis只想保存其中一万个热点数据...

1. 简单介绍一下你自己 2. 把你的项目功能模块、用到的技术说一说 3. cookie和session的区别 4. JVM内存区域 5. hashmap和concurrentHashMap的区别 6. 说一说对工厂模式的理解(自己说到简单工厂和抽象工厂时忘记了) 7. 你可以回去了....(连二面都没有)

一面:   1.自我介绍 2.介绍项目 3.订单模块如何实现的 4.支付宝如何对接和处理的 5.一个方法有个参数，异步出去去处理(打印)这个参数 6.一个数组，数字无序，快速找到两个数字，他们之和等于n 7.实现一个迭代器类，有两个方法，一个是next，一个是peek(这一题首先可以用java的迭代器，然后要注意获取第一个元素，存到一个变量，后面peek方法要用，还有一些细节要处理不赘述) 8.可能还有其他问题，忘记了，主要是上面，面试官态度超级好，阿里的大牛，一步一步引导我，很感激  二面: 1.自我介绍 2.磁盘或者内存，由于每次存储的内容大小都不一样，假设有1k，2k,5k等若干大小的数...

海康的两面    自我介绍   项目架构   java集合的几种接口，分别说说   内存溢出以及如何解决，如何监控   集合遍历的时候进行修改如何解决   死锁如何监控，实现一个死锁   如何进行对象的拷贝   序列化存在的问题   你的系统是如何进行权限校验的   ssm整合的关键步骤   事务的配置，隔离级别如何配置的   你的压力来源于哪   你的缺点   你如何证明你学习的进展和高度    中国电信IT研发中心的两面    LongAdder&AtomicLong的区别   JVM内存区域，其中堆区着重讲一下   TreeMap如何保证有序，红黑树基本原理，红黑树存在的意义  ...