kafka+topic
作者&投稿：以贾 （若有异议请与网页底部的电邮联系）
淫店13156231083问： 如何在Kafka上创建一个Topic - ？
湖北省双甲回答： Kafka创建Topic步骤: 进入服务器找kafka安装目录进入bin文件夹输入命令--- 查看kafka现主题命令:/kafka-topics.sh --list --zookeeper zk_host:port 望采
淫店13156231083问： kafka只能用命令来创建topic么 - ？
湖北省双甲回答： 在Kafka上创建一个Topic的步骤:进入服务器后,找到kafka安装目录进入bin文件夹,输入命令--- 查看kafka现有主题命令:./kafka-topics.sh --list --zookeeper zk_host:port望采纳.
淫店13156231083问： kafka能做topic广播吗?？
湖北省双甲回答：bg4.png 可以的只要groupID不一样就行但是不知道storm kafka里怎么哪个字段是设置groupid的
淫店13156231083问： kafka中的topic为什么要进行分区 - ？
湖北省双甲回答： 若没有分区,一个topic对应的消息集在分布式集群服务组中,就会分布不均匀,即可能导致某台服务器A记录当前topic的消息集很多,若此topic的消息压力很大的情况下,服务器A就可能导致压力很大,吞吐也容易导致瓶颈.有了分区后,假设一个topic可能分为10个分区,kafka内部会根据一定的算法把10分区尽可能均匀分布到不同的服务器上,比如:A服务器负责topic的分区1,B服务器负责topic的分区2,在此情况下,Producer发消息时若没指定发送到哪个分区的时候,kafka就会根据一定算法上个消息可能分区1,下个消息可能在分区2.当然高级API也能自己实现其分发算法.
淫店13156231083问： 如何为Kafka集群选择合适的Topics/Partitions数量 - ？
湖北省双甲回答： 如何决定kafka集群中topic,partition的数量,这是许多kafka用户经常遇到的问题.本文列举阐述几个重要的决定因素,以提供一些参考.分区多吞吐量更高 一个话题topic的各个分区partiton之间是并行的.在producer和broker方面,写不同的分区...
淫店13156231083问： kafka中的topic为什么要进行分区 - ？
湖北省双甲回答： kafka topic 分区的原因主要是为了并发访问,增大吞吐量.具体来讲,每一个topic均被分成多个互不重复的partition,其中每个partition均被放在一个或多个broker服务器上,这样就提供了容错.如果数据在不同的patition上,那么他们的访问将可能由不同的broker服务器来完成,这样就实现了并发访问.分区的信息储存在Zookeeper上.所以,分区是kafka用来提供并发访问控制的一个概念.
淫店13156231083问： kafka只监听一个topic的信息吗 - ？
湖北省双甲回答： 1. 从zookeeper的/brokers/topics节点下获取所有topic封装成topic集合2. 遍历该集合,查看每个topic是否是待删除topic——即在/admin/delete_topics下是否存在同名节点.如果是,打印topic已经被标记为删除;否则直接打印topic名称
淫店13156231083问： 怎么彻底删除kafka的topic,然后重建 - ？
湖北省双甲回答： 1. 删除logs下的相关记录; 2. 到zookeeper下的brokers/topics删除相关节点.--------------不好用!!先逻辑删除(./bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic dnsTopic --zookeeper 10.0.1.44:2181,10.0.1.45:2181,10.0.1.46...
淫店13156231083问： 如何删除kafka的topic 分区 - ？
湖北省双甲回答： 第一,把系统装在C盘,D,E,F盘内容不会消失,第二,分区,个人觉得分区可以安软件,游戏,电影,软件一般分10个G,游戏一般分30G,其它电影.第三,游戏不要放C盘就行了.最好安装有一定的空间的盘里.第四,每安装一个应用程序,都可以更改路径的.第五,你可以把桌面上的我的文档,改到D盘,可以结约一布分的系统空间.
淫店13156231083问： 多个topic怎么设置kafkaspout java例子 - ？
湖北省双甲回答： +t)?＂1+2=几.out:＂当然是; t=add(i,j).println(".println("public class j { static int add(int a,int b){ int s; s=a+b; System; } public static void main(String args[]){ int i=1,j=2; int t;); System; return s.out
