搜索结果
查询Tags标签： kafka，共有 918条记录-
MaxWell ops
Download Download binary distro: https://github.com/zendesk/maxwell/releases/download/v1.33.0/maxwell-1.33.0.tar.gz Sources and bug tracking is available on github: https://github.com/zendesk/maxwell homebrew: brew install maxwellConfigure $ vi my.cnf…
2021/5/6 18:28:48 人评论 次浏览 -
最新2021年Java大厂面试经验，附答案解析
前言 说起来开始进行面试是年前倒数第二周，上午9点，我还在去公司的公交上，突然收到蚂蚁的面试电话，其实算不上真正的面试。面试官只是和我聊了下他们在做的事情（主要是做双十一这里大促的稳定性保障，偏中间件吧），说的很详细，然后和我沟通了下是否有兴趣，我表示有…
2021/5/6 14:25:38 人评论 次浏览 -
kafka基础
这里写目录标题 MQ基础架构生产消费常见问题MQ基础 MQ的应用场景： 异步处理 - 相比于传统的串行、并行方式，提高了系统吞吐量。应用解耦 - 系统间通过消息通信，不用关心其他系统的处理。流量削锋 - 可以通过消息队列长度控制请求量；可以缓解短时间内的高并发请求。日志…
2021/5/3 18:56:14 人评论 次浏览 -
2021年大数据Flink（三十七）：???????Table与SQL ??????案例四
目录 案例四 需求 代码实现案例四 需求 从Kafka中消费数据并过滤出状态为success的数据再写入到Kafka{"user_id": "1", "page_id":"1", "status": "success"}{"user_id&qu…
2021/5/3 2:25:16 人评论 次浏览 -
sparkstreaming对接kafka数据，在idea程序上出现警告信息并卡住不动的解决办法
spark jira 用中文的同学看了我笑了，牛啊 Unexpected delay before fetch response transmission Details Type:Bug Status:Open Priority: Major Resolution: Unresolved Affects Version/s: 0.9.0.0, 0.9.0.1, 0.10.0.0, (3) 0.10.0.1, 0.10.1.0, 0.10.1.1 Fix Versi…
2021/5/2 20:30:25 人评论 次浏览 -
CentOS-Docker搭建Kafka(单点，含：zookeeper、kafka-manager)
Docker搭建Kafka(单点，含：zookeeper、kafka-manager)下载相关容器$ docker pull wurstmeister/zookeeper $ docker pull wurstmeister/kafka $ docker pull sheepkiller/kafka-manager 运行相关容器启动zookeeper$ docker run -d --name zookeeper --publish 2181:2181 …
2021/5/1 7:28:20 人评论 次浏览 -
玩转MySQL：Java高级工程师面试实战，深入分析
一、背景 我们日常在电商网站购物时经常会遇到一些高并发的场景，例如电商 App 上经常出现的秒杀活动、限量优惠券抢购，还有我们去哪儿网的火车票抢票系统等，这些场景有一个共同特点就是访问量激增，虽然在系统设计时会通过限流、异步、排队等方式优化，但整体的并发还是…
2021/4/30 19:27:48 人评论 次浏览 -
Kafka启动遇到ERROR Exiting Kafka due to fatal exception (kafka.Kafka$) 解决办法 从kafka的根目录启动 bin/kafka-serve
Mysql配置读写数据库 ERROR 1227 (42000): Access denied; you need (at least one of) the SUPER privilege(s) for this operation 原因之前mysql的vi /etc/my.cnf修改配置没有重启() mysql从服务器 #指定从库serverid server-id=2 保存退出 service mysqld restart
2021/4/30 10:55:10 人评论 次浏览 -
「Spring和Kafka」Kafka深挖第4部分：事件流管道的连续交付
对于事件流应用程序开发人员，根据管道中各个应用程序的更改需要不断更新流管道非常重要。理解流开发人员用于构建事件流管道的一些常见流拓扑也很重要。在Apache Kafka Deep Dive博客系列的Spring的第4部分中，我们将讨论:Spring云数据流支持的通用事件流拓扑模式在Sprin…
2021/4/30 10:30:49 人评论 次浏览 -
flink sink到kafka 默认分区器 FlinkFixedPartitioner相关源码分析
1、flink和kafka交互有两种jar包: 通过maven仓库搜索 https://mvnrepository.com/search?q=org.apache.flink+++flink-connector-kafka-老的jar包有三种： 0.11版本(只更新到1.11.x)：<dependency><groupId>org.apache.flink</groupId><artifactId&…
2021/4/29 22:25:08 人评论 次浏览 -
python操作kafka
1.生产者推送# pip install kafka-python import json import time import datetime from kafka import KafkaProducertopic=topic server="ip:port" # 测试版：无用户名密码 # value_serializer 指定序列号方式，传入字典，转成json字符串def producer():produ…
2021/4/29 20:28:59 人评论 次浏览 -
2021金三银四面试季！2021新一波程序员跳槽季，知乎上转疯了！
前言： 有人说世界上有三个伟大的发明：火，轮子，以及 Kafka。 发展到现在，Apache Kafka 无疑是很成功的，Confluent 公司曾表示世界五百强中有三分之一的企业在使用 Kafka。在流式计算中，Kafka 一般用来缓存数据，例如 Flink 通过消费 Kafka 的数据进行计算。 而要谈对…
2021/4/29 12:27:53 人评论 次浏览 -
35岁程序员：Java开发你需要了解的那些事，面试必问！
前言： 首先介绍一下我的同学，专科毕业应用电子技术专业，已经毕业快两年了。因为专业的原因工作一年觉得没什么发展前途就想转行，身为他的“好基友”，他觉得我这个工作挺好的，就咨询了我一下，经过的严厉拒绝下（各种诱惑下），还是阻挡不了他。随后他报名了北大某鸟…
2021/4/29 12:27:32 人评论 次浏览 -
为什么数据库会丢失数据？大厂面经合集
引言 技术好就一定能写出优质的代码吗？不能，对于做开发的人来说，学到的技术知识是理论性的，只有把知识代入到真实的实战案例中才能快速将理论转变为技能。 一直在网上看到过很多关于类似的资料，要么就是版本比较老，要么就是讲的太干，没有阅读下去的兴趣，以至于在这…
2021/4/28 19:28:14 人评论 次浏览 -
金三银四旗开得胜！原来大厂的Redis分布式锁都这么设计的！干货整理
前言 刚刚过去的双十一，让“高性能”“高可用”“亿级”这3个词变成了技术热点词汇，也让很多人再次萌发成为「架构师」的想法。先问大家一个问题：你觉得把代码熟练、完成需求加上点勤奋，就能成为架构师么？如果你这么认为，那你注定只能是“码农”。从业这么多年，我见…
2021/4/27 19:28:30 人评论 次浏览
