码迷,mamicode.com
首页 >  
搜索关键字:Kafka    ( 4273个结果
使用Java API创建(create),查看(describe),列举(list),删除(delete)Kafka主题(Topic)
使用Kafka的同学都知道,我们每次创建Kafka主题(Topic)的时候可以指定分区数和副本数等信息,如果将这些属性配置到server.properties文件中,以后调用Java API生成的主题将使用默认值,先改变需要使用命令bin/kafka-topics.sh --zookeeper lo...
分类:编程语言   时间:2015-05-28 17:45:49    阅读次数:458
kafkakafka_2.10-0.8.2.1+zookeeper-3.4.6 创建topic一个小问题
kafka创建topic时出现如下异常:Errorwhileexecutingtopiccommandorg.apache.zookeeper.KeeperException$NoNodeException:KeeperErrorCode=NoNodefor/brokers/idsorg.I0Itec.zkclient.exception.ZkNoNodeException:org.apache.zookeeper.KeeperException$NoNodeException:Keeper..
分类:其他好文   时间:2015-05-28 14:26:09    阅读次数:2040
【原创】kafka server源代码分析(一)
这个是Kafka server的核心包,里面的类也很多,我们还是一个一个分析一、BrokerStates.scala定义了目前一个kafka broker的7中状态 ——1. NotRunning:未运行2. Starting:启动中3. RecoveringFromUncleanShutdown:...
分类:其他好文   时间:2015-05-28 09:26:17    阅读次数:4713
kafka+zookeeper环境配置(Mac 或者 linux环境)
一.zookeeper下载与安装1)下载adeMacBook-Pro:zookeeper_soft apple$ wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz2)解压tar z...
分类:系统相关   时间:2015-05-27 20:50:37    阅读次数:365
Kafka设计解析(二) Kafka High Availability (上)
摘要 Kafka在0.8以前的版本中,并不提供High Availablity机制,一旦一个或多个Broker宕机,则宕机期间其上所有Partition都无法继续提供服务。若该Broker永远不能再恢复,亦或磁盘故障,则其上数据将丢失。而Kafka的设计目标之一即是提供数据持久化,同时对于分布式系....
分类:其他好文   时间:2015-05-27 15:23:04    阅读次数:132
Kafka集群安装
下载kafka正式版 http://kafka.apache.org/downloads.html 在Linux下解压tar包 tar -xzfkafka_2.9.2-0.8.1.1.tgz 修改server.properties 进入kafka根目录config/server.properties 主要修改的有3个参数如下:...
分类:其他好文   时间:2015-05-25 18:51:27    阅读次数:248
kafka迁移与扩容
参考官网site:http://kafka.apache.org/documentation.html#basic_ops_cluster_expansionhttps://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Rep...
分类:其他好文   时间:2015-05-25 18:35:21    阅读次数:146
Kafka Topic动态迁移 (源代码解析)
总结下自己在尝试Kafka分区迁移过程中对这部分知识的理解,请路过高手指正。关于Kafka数据迁移的具体步骤指导,请参考如下链接:http://www.cnblogs.com/dycg/p/3922352.html原文作者写的非常清晰。本文主要侧重自己对相关Kafka源代码的理解:generateA...
分类:其他好文   时间:2015-05-25 18:31:41    阅读次数:471
Kafka的Producer和Consumer源码学习
先解释下两个概念:high watermark (HW) 它表示已经被commited的最后一个message offset(所谓commited, 应该是ISR中所有replica都已写入),HW以下的消息都已被ISR中各个replica同步,从而保持一致。HW以上的消息可能是脏数据:部分repl...
分类:其他好文   时间:2015-05-25 18:27:04    阅读次数:271
Kafka中的Message Delivary机制
学习Kafka的读书笔记,暂未把文章设为翻译类型,因为并非直译文档。水平有限,还请路过高手指正。 “最多(发送)一次”(At most once):消息可以丢失但绝不会重新发送; “至少(发送)一次”(At least once):消息绝不会丢失但是可能会被重新发送; “仅(发送)一次”(Exact...
分类:其他好文   时间:2015-05-25 18:15:55    阅读次数:134
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!