搜索结果
查询Tags标签： kafka，共有 918条记录-
Spark综合性练习(Spark，Kafka，Spark Streaming，MySQL)
写在前面： 博主是一名大数据的初学者，昵称来源于《爱丽丝梦游仙境》中的Alice和自己的昵称。作为一名互联网小白，写博客一方面是为了记录自己的学习历程，一方面是希望能够帮助到很多和自己一样处于起步阶段的萌新。由于水平有限，博客中难免会有一些错误，有纰漏之处恳…
2021/6/1 19:21:38 人评论 次浏览 -
一文告诉你SparkStreaming如何整合Kafka!
关于SparkStreaming从理论到实战的部分，博主已经在前面的博客中介绍了。本篇博客，为大家带来的是SparkStreaming整合Kafka的教程!文章目录 Kafka回顾 整合kafka两种模式说明 1.Receiver接收方式： 2.Direct直连方式spark-streaming-kafka-0-8(了解) 1.Receiver 2.Direct…
2021/6/1 18:25:41 人评论 次浏览 -
被大佬问到自闭！java游戏源码
一、前言Redis 提供了5种数据类型：String（字符串）、Hash（哈希）、List（列表）、Set（集合）、Zset（有序集合），理解每种数据类型的特点对于redis的开发和运维非常重要。备注： 按照分析顺序，本节应该说道有序集合对象了，但是考虑到有序集合对象的底层实现中使用到…
2021/6/1 12:26:23 人评论 次浏览 -
?漫画：什么是Base64算法？
玻璃猫 程序员小灰 ValueCharValueCharValueCharValueChar0A16Q32g48w1B17R33h49x2C18S34i50y3D19T35j51z4E20U36k5205F21V37l5316G22W38m5427H23X39n5538I24Y40o5649J25Z41p57510K26a42q58611L27b43r59712M28c44s60813N29d45t61914O30e46u62+15P31f47v63/控制字符：可打印…
2021/5/30 22:24:14 人评论 次浏览 -
Java岗面试：java开发是什么职业
前言： 有人说世界上有三个伟大的发明：火，轮子，以及 Kafka。 发展到现在，Apache Kafka 无疑是很成功的，Confluent 公司曾表示世界五百强中有三分之一的企业在使用 Kafka。在流式计算中，Kafka 一般用来缓存数据，例如 Flink 通过消费 Kafka 的数据进行计算。 而要谈对…
2021/5/25 12:26:23 人评论 次浏览 -
美团Java面试题，苹果手机java编程软件
开头 我们面试的时候 ，经常会被问这种到问题:Spring中bean的循环依赖怎么解决？ Spring中bean的加载过程？ spring相关的问题一直是大厂面试常问到的一个问题,也是一直困扰这我们，不知道从哪里下手，今天举例分析大厂的一些spring相关的面试真题。和分享我学习spring相关…
2021/5/24 20:57:17 人评论 次浏览 -
关于Kafka些测试消费类后，消费Kafka集群Brocker上得数据报错解决Marking the coordinator storage12.babel:7667 (id: 2147483645
在搭建完成Kafka消费系统后，启动消费程序取消费平台得数据，出现如下得错误： 报错信息：2021/05/24 16:55:17 118 INFO authenticator.AbstractLogin:59 - Successfully logged in. 2021/05/24 16:55:17 150 INFO utils.AppInfoParser:83 - Kafka version : 0.10.2.…
2021/5/24 18:31:31 人评论 次浏览 -
ELK 最详细安装及介绍
这里是目录介绍 组件介绍： Elasticsearch： Logstash： Kibana： Kafka： Filebeat：实验环境： 实验步骤： 1、安装JDK，因为es运行依赖jdk 2、安装并配置ES 2.1、创建运行es的普通用户 2.2、安装配置ES 2.3、设置JVM堆大小 2.4、创建es数据及日志存储目录 2.5、修改安装…
2021/5/24 18:30:59 人评论 次浏览 -
kafka自定义producer从mysql获取数据存储至kafka
package test;/*** @Description 细节决定成败* @Date 2021/5/23 14:45* @Author liaoxuan**/import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import kafka.producer.ProducerConfig; import kafka.serializer.StringEncoder; import util…
2021/5/23 19:27:16 人评论 次浏览 -
kafka在Java中常用API的使用
新建maven工程 导入maven依赖 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http:…
2021/5/22 20:26:10 人评论 次浏览 -
Kafka学习-基础知识
一、基本定义 Apache Kafka是一个基于分布式发布 - 订阅模式的消息系统，可以处理大量的数据，并能够将消息从一个端点传递到另一个端点。 Kafka适合离线和在线消息消费。 Kafka将消息按顺序保存在磁盘上，并在群集内复制以防止数据丢失。 Kafka构建在ZooKeeper同步服务之…
2021/5/22 18:55:52 人评论 次浏览 -
干货精讲！java程序设计选择题题库
前言 提起MySQL，其实网上已经有一大把教程了，为什么我还要写这篇文章呢，大概是因为网上很多网站都是比较零散，而且描述不够直观，不能系统对MySQL相关知识有一个系统的学习，导致不能形成知识体系。为此我撰写了这篇文章，试图让这些底层架构相关知识更加直观易懂： 尽…
2021/5/21 20:25:39 人评论 次浏览 -
爱了爱了！解锁Java性能优化的五大误区
Kafka宕机引发的高可用问题 问题要从一次Kafka的宕机开始说起。 笔者所在的是一家金融科技公司，但公司内部并没有采用在金融支付领域更为流行的RabbitMQ，而是采用了设计之初就为日志处理而生的Kafka，所以我一直很好奇Kafka的高可用实现和保障。从Kafka部署后，系统内部…
2021/5/21 14:25:34 人评论 次浏览 -
Java面试题2020，我凭着这份《Kafka源码实战》碾压面试官
Kafka宕机引发的高可用问题 问题要从一次Kafka的宕机开始说起。 笔者所在的是一家金融科技公司，但公司内部并没有采用在金融支付领域更为流行的RabbitMQ，而是采用了设计之初就为日志处理而生的Kafka，所以我一直很好奇Kafka的高可用实现和保障。从Kafka部署后，系统内部…
2021/5/21 12:26:49 人评论 次浏览 -
mysql-u不是内部或外部命令，圆我大厂梦！
为什么要优化 Ngin HTTPS 延迟 Nginx 常作为最常见的服务器，常被用作负载均衡 (Load Balancer)、反向代理 (Reverse Proxy)，以及网关 (Gateway) 等等。一个配置得当的 Nginx 服务器单机应该可以 期望承受住 50K 到 80K 左右 [1] 每秒的请求，同时将 CPU 负载在可控范围内…
2021/5/20 19:29:52 人评论 次浏览
