小编Nic*_*ole的帖子

创建Kafka主题时出错 - 复制因子大于可用代理

我正在尝试通过命令行遵循Apache Kafka网站上的指南在Kafka中创建主题.在运行命令时:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
Run Code Online (Sandbox Code Playgroud)

我得到的错误如下:

Error while executing topic command replication factor: 1 larger than available
brokers: 0
kafka.admin.AdminOperationException: replication factor: 1 larger than available
 brokers: 0
        at kafka.admin.AdminUtils$.assignReplicasToBrokers(AdminUtils.scala:70)
        at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:171)
        at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:93)
        at kafka.admin.TopicCommand$.main(TopicCommand.scala:55)
        at kafka.admin.TopicCommand.main(TopicCommand.scala)

[2015-10-13 14:25:38,607] INFO Processed session termination for sessionid: 0x15
06056566d0004 (org.apache.zookeeper.server.PrepRequestProcessor)
[2015-10-13 14:25:38,608] INFO Closed socket connection for client /127.0.0.1:33
391 which had sessionid 0x1506056566d0004 (org.apache.zookeeper.server.NIOServer
Cnxn)
Run Code Online (Sandbox Code Playgroud)

我该如何解决这个问题?有什么好的文档来开始这个吗?谢谢!!

apache-kafka

37
推荐指数
6
解决办法
5万
查看次数

SparkSQL使用Python从MySQL数据库表中读取

我在MySQL中有一个'用户'表.我想把它读到我的Spark SQL程序.如何使用Python从MySQL读取表格到Apache Spark的SparkSQL模块?我可以使用连接器执行此任务吗?谢谢.

python apache-spark-sql pyspark

13
推荐指数
1
解决办法
1万
查看次数

Node.js Web应用程序的国际化(i18n)/本地化

我使用Node.js构建Web应用程序.我希望国际化并支持英语和西班牙语.

每当用户选择英文链接时,我的'index.ejs'页面的静态内容应该是英文的,当他选择西班牙语时,它应该相应地改变.

我怎样才能做到这一点?最简单的方法是什么?另外,我如何改进搜索引擎优化(SEO)?

javascript internationalization node.js web

5
推荐指数
1
解决办法
547
查看次数