包含标签：kafka 的文章
-
说说Lambda架构
分析&回答 Lambda架构是由Storm的作者Nathan Marz提出的一个实时大数据处理框架。Marz在Twitter工作期间开发了著名的实时大数据处理框架Storm，Lambda架……admin 5天前
-
kafka复习：（20）：消费者拦截器的使用
一、定义消费者拦截器（只消费含"sister"的消息） package com.cisdi.dsp.modules.metaAnalysis.rest; import org.apache.kafka.clients.consumer.ConsumerI…… -
Java自学到什么程度就可以去找工作了?
引言 Java作为一门广泛应用于软件开发领域的编程语言，对于初学者来说，了解到什么程度才能开始寻找实习和入职机会是一个常见的问题。 本文将从实习和入…… -
kafka-2.12使用记录
kafka-2.12使用记录 安装kafka 2.12版本 下载安装包 根据你的系统下载rpm /deb /zip包等等, 这里我使用的是rpm包 安装命令 rpm -ivh kafka-2.12-1.nfs.x86…… -
大数据面试题：Kafka的ISR机制
面试题来源： 《大数据面试题 V4.0》 大数据面试题V3.0，523道题，679页，46w字 可回答：1）从ISR踢出去之后呢；2）一般Leader怎么判断Follower挂掉？ 参考答…… -
踩坑（5）整合kafka 报错 java.net.UnknownHostException: 不知道这样的主机
java.net.UnknownHostException: 不知道这样的主机。 (5c0c3c629db9) at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method) ~[na:na] …… -
Kafka 入门到起飞 – Kafka怎么做到保障消息不会重复消费的？ 消费者组是什么？
Kafka怎么做到避免消息重复消费的？ 消费者组是什么？ 消费者： 1、订阅Topic（主题） 2、从订阅的Topic消费（pull）消息， 3、将消费消息的offset（偏移量…… -
kafka第三课-可视化工具、生产环境问题总结以及性能优化
一、可视化工具 https://pan.baidu.com/s/1qYifoa4 密码：el4o 下载解压之后，编辑该文件，修改zookeeper地址，也就是kafka注册的zookeeper的地址，如果…… -
Kafka：消费者消费失败处理-重试队列
kafka没有重试机制不支持消息重试，也没有死信队列，因此使用kafka做消息队列时，需要自己实 现消息重试的功能。 实现 创建新的kafka主题作为重试队列： 创…… -
kafka系统的架构
系统的架构 主题topic和分区partition topic Kafka中存储数据的逻辑分类；你可以理解为数据库中“表”的概念； 比如，将app端日志、微信小程序端日志、……