腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
首页
学习
活动
专区
工具
TVP
最新优惠活动
返回腾讯云官网
悠扬前奏的博客
专栏成员
举报
333
文章
267510
阅读量
32
订阅数
订阅专栏
申请加入专栏
全部文章(333)
编程算法(122)
java(64)
python(21)
linux(18)
sql(17)
javascript(12)
node.js(12)
bash(11)
xml(11)
ide(11)
自动驾驶(10)
打包(10)
网站(10)
jvm(10)
数据结构(10)
kafka(10)
数据库(9)
api(9)
线程(9)
字符串(9)
scala(8)
bash 指令(8)
http(8)
socket编程(8)
pandas(8)
unix(7)
spring(7)
文件存储(7)
缓存(7)
tcp/ip(7)
tomcat(6)
maven(6)
spark(6)
正则表达式(6)
二叉树(6)
int(6)
数组(6)
负载均衡(5)
html(5)
eclipse(5)
jar(5)
spring boot(5)
nat(5)
min(5)
thread(5)
语法(5)
php(4)
apache(4)
NAT 网关(4)
shell(4)
mybatis(4)
yum(4)
面向对象编程(4)
dataframe(4)
max(4)
nan(4)
ode(4)
函数(4)
排序(4)
其他(3)
c++(3)
servlet(3)
SSL 证书(3)
存储(3)
网络安全(3)
jdbc(3)
数据分析(3)
windows(3)
虚拟化(3)
join(3)
neo4j(3)
numbers(3)
series(3)
set(3)
sum(3)
txt(3)
同步(3)
机器学习(2)
jquery(2)
android(2)
云数据库 SQL Server(2)
负载均衡缓存(2)
腾讯云测试服务(2)
容器(2)
分布式(2)
ftp(2)
zookeeper(2)
gcc(2)
微服务(2)
groovy(2)
axis(2)
boolean(2)
com(2)
file(2)
function(2)
hash(2)
having(2)
key(2)
label(2)
lint(2)
list(2)
network(2)
null(2)
object(2)
protected(2)
public(2)
range(2)
release(2)
return(2)
rows(2)
string(2)
target(2)
timestamp(2)
vi(2)
void(2)
wait(2)
二进制(2)
基础(2)
脚本(2)
内存(2)
数据(2)
统计(2)
效率(2)
对象存储(1)
c 语言(1)
jsp(1)
regex(1)
云数据库 Redis(1)
access(1)
mvc(1)
git(1)
svn(1)
matlab(1)
ubuntu(1)
centos(1)
nginx(1)
神经网络(1)
深度学习(1)
mapreduce(1)
日志服务(1)
命令行工具(1)
消息队列 CMQ 版(1)
文字识别(1)
数据工坊(1)
云推荐引擎(1)
人工智能(1)
图像处理(1)
企业(1)
开源(1)
jdk(1)
hadoop(1)
ssh(1)
gui(1)
numpy(1)
dns(1)
hashmap(1)
aop(1)
markdown(1)
rpc(1)
udp(1)
kernel(1)
uml(1)
anaconda(1)
大数据(1)
安全(1)
数据处理(1)
https(1)
学习方法(1)
add(1)
alpha(1)
apply(1)
background(1)
binary(1)
bit(1)
break(1)
browser(1)
case(1)
cat(1)
channel(1)
class(1)
connect(1)
count(1)
countdown(1)
daemon(1)
digits(1)
display(1)
dsl(1)
enums(1)
equals(1)
filter(1)
geo(1)
gps(1)
guava(1)
init(1)
interrupt(1)
jit(1)
limit(1)
line(1)
localhost(1)
lock(1)
mac(1)
message(1)
na(1)
nodes(1)
panel(1)
private(1)
publish(1)
relationship(1)
rename(1)
replace(1)
reset(1)
restart(1)
reverse(1)
row(1)
security(1)
select(1)
semaphore(1)
service(1)
simpledateformat(1)
size(1)
sleep(1)
sms(1)
sort(1)
state(1)
static(1)
stringbuilder(1)
submit(1)
tail(1)
terminal(1)
threadpoolexecutor(1)
time(1)
timedelta(1)
timeout(1)
transform(1)
union(1)
variables(1)
window(1)
遍历(1)
变量(1)
编码(1)
编译(1)
队列(1)
对象(1)
服务(1)
集合(1)
技巧(1)
加密(1)
垃圾回收(1)
乱码(1)
排序算法(1)
设计(1)
索引(1)
性能(1)
异常(1)
优化(1)
指针(1)
日志文件(1)
搜索文章
搜索
搜索
关闭
Kafka-15.实现-分发
kafka
文件存储
Kafka消费者跟踪它在每个分区消费的最大偏移量,并且能够提交偏移量,以便在重新启动的时候可以从这些偏移量中恢复。Kafka提供了在指定broker(针对该组)中将给定消费者组的所有偏移量存储为group coordinator的选项。即,改消费者组中的任何消费者实例应将其偏移量提交和提取发送给该group coordinator。消费者可以通过任何Kafka broker发出FindCoordinatorRequest并读取包含包含协调器详细信息的FindCoordinatorResponse来查找其协调器。然后,消费者可以继续从coordinator broker处理提交或者获取偏移量。在coordinator 移动的情况下,消费者需要重新发现coordinator。偏移调教可以由消费者实例自动或手动完成。
悠扬前奏
2019-07-01
387
0
Kafka-12.设计-配额
kafka
api
Kafka集群能够对请求实施配额,以控制客户端使用的broker资源。 Kafka broker可以为共享配额的每组客户强制执行两种类型的客户配额:
悠扬前奏
2019-06-19
588
0
Kafka-11.设计-日志压缩
kafka
文件存储
日志压缩可以保证Kafka总是最少保留单个主题分区的数据日志中的每个消息的key的最后的已知值。(Log compaction ensures that Kafka will always retain at least the last known value for each message key within the log of data for a single topic partition. )它address了用例和处理方案,例如应用程序崩溃或者系统故障后的状态恢复,或在运行维护期间重启应用后如何加载缓存。让我们更详细的介绍这些情况,然后描述是如何压缩的: 到目前为止,我们仅描述了简单一些的数据保留方法,其中旧的日志数据在固定时间段或者当日志达到某个预定大小时被丢弃。这适用于时间事件数据,例如记录独立的日志记录。但是,一类重要的数据流是keyed更改的日志(例如,对数据库表的更改)。
悠扬前奏
2019-06-19
590
0
Kafka-10.设计-复制
kafka
分布式
zookeeper
Kafka在可配置数量的服务器上复制每个主题分区的日志(您可以逐个主题地设置此复制因子)。这允许在群集中的服务器发生故障时自动故障转移到这些副本,以便在出现故障时消息仍然可用。
悠扬前奏
2019-06-16
516
0
Kafka-9.设计-消息分发语义
kafka
在了解了生产者和消费者的工作方式之后,我们来讨论Kafka在生产者和消费者之间提供的语义保证。 显然,有多个可能的消息专题保证可以提供:
悠扬前奏
2019-06-15
492
0
Kafka-7.设计-生产者,消费者,效率
windows
kafka
生产者将数据直接发送到作为分区leader的broker,而不需要任何中间路由曾。为了帮助生产者执行此操作,所有kafka节点都可以回答有关于那些服务器处于活动状态的源数据请求一级主题分区的leader在任何给定时间的位置,以允许生产者合适的指向它的请求。
悠扬前奏
2019-06-15
409
0
Kafka-6.配置-Kafka Connect Configs
linux
编程算法
python
kafka
node.js
3.5 Kafka Connect Configs 下面是Kafka Connect 框架的配置: NAME DESCRIPTION TYPE DEFAULT VALID VALUES IMPORTANCE config.storage.topic The name of the Kafka topic where connector configurations are stored string high group.id A unique string that identifies the Co
悠扬前奏
2019-06-11
1.8K
2
Kafka-1.APIS
kafka
maven
scala
api
Kafka通过一个语言独立的协议发布其所有功能,这个协议在很多编程语言都有可用的客户端。不过只有Java客户端是作为主要Kafka项目的一部分来维护的,其他客户端是以独立的开源项目提供的。无Java客户端在这里提供。
悠扬前奏
2019-06-11
676
0
Kafka-7.设计
缓存
kafka
数据结构
Kafka设计的目的是为能作为一个统一的平台来处理大公司可能有的实时数据流。为此,需要考虑相当广泛的用例。
悠扬前奏
2019-06-11
532
0
Kafka-0.开始
windows
api
kafka
消息队列 CMQ 版
编程算法
在Kafka中,每一个客户端和服务器的连接都以一种简单的,高性能的,语言无关的TCP协议完成。这个协议的版本能够向后维护来兼容旧版本。我们提供了一个Java客户端,但是客户端其实在很多语言中都可用。
悠扬前奏
2019-05-28
633
0
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
立即查看
Python精品学习库
代码在线跑,知识轻松学
立即查看
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
立即体验
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
立即查看
领券
问题归档
专栏文章
快讯文章归档
关键词归档
开发者手册归档
开发者手册 Section 归档