`
kfcman
  • 浏览: 395528 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

kafka不能启动

 
阅读更多

近期在搭建一个kafka集群的时候。碰到一个很奇怪的问题。相关报错如下:
[2014-05-07 14:18:24,439] INFO [Kafka Server 2], Starting (kafka.server.KafkaServer)
[2014-05-07 14:18:24,457] INFO [Log Manager on Broker 2] Loading log 'kafka_metrics' (kafka.log.LogManager)
[2014-05-07 14:18:24,473] FATAL Fatal error during KafkaServerStable startup. Prepare to shutdown (kafka.server.KafkaServerStartable)
java.lang.StringIndexOutOfBoundsException: String index out of range: -1
 at java.lang.String.substring(String.java:1911)
 at kafka.log.LogManager.kafka$log$LogManager$$parseTopicPartitionName(LogManager.scala:335)
 at kafka.log.LogManager$$anonfun$loadLogs$1$$anonfun$apply$3.apply(LogManager.scala:112)
 at kafka.log.LogManager$$anonfun$loadLogs$1$$anonfun$apply$3.apply(LogManager.scala:109)
 at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
 at scala.collection.mutable.ArrayOps.foreach(ArrayOps.scala:34)
 at kafka.log.LogManager$$anonfun$loadLogs$1.apply(LogManager.scala:109)
 at kafka.log.LogManager$$anonfun$loadLogs$1.apply(LogManager.scala:101)
 at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34)
 at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32)
 at kafka.log.LogManager.loadLogs(LogManager.scala:101)
 at kafka.log.LogManager.(LogManager.scala:62)
 at kafka.server.KafkaServer.startup(KafkaServer.scala:63)
 at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:34)
 at kafka.Kafka$.main(Kafka.scala:46)
 at kafka.Kafka.main(Kafka.scala)
[2014-05-07 14:18:24,474] INFO [Kafka Server 2], Shutting down (kafka.server.KafkaServer)
[2014-05-07 14:18:24,476] INFO Shutdown Kafka scheduler (kafka.utils.KafkaScheduler)
[2014-05-07 14:18:24,476] INFO [Kafka Server 2], Shut down completed (kafka.server.KafkaServer)
[2014-05-07 14:18:24,477] INFO [Kafka Server 2], Shutting down (kafka.server.KafkaServer)

经过一番查找,终于知道原因,是因为在kafka的server.properties中。
log.dir=/home/data/kafka和kafka.csv.metrics.dir=/home/data/kafka
目录相同。造成的。

分享到:
评论

相关推荐

    Windows zookeeper/kafka开启自启动

    Windows 环境 为zookeeper和kafka配置开机自启动服务。

    kafka 部署成windows服务

    4. 使用NSSM设置Kafka服务的启动参数,如工作目录、环境变量等。 5. 安装Kafka服务,可以通过命令行或服务管理器启动和停止服务。 6. 验证服务是否正常运行,通过Kafka的命令行工具检查集群状态。 在实际应用中,还...

    Kafka快速启动.pdf

    Kafka快速启动

    5、kafka监控工具Kafka-Eagle介绍及使用

    在 Kafka 的启动脚本中添加 `JMX_PORT=9988`,然后使用 nohup 命令后台启动 Kafka。 接下来,安装 Kafka-Eagle 包括以下步骤: 1. **安装 JDK**:Kafka-Eagle 需要 Java 运行环境,确保 `JAVA_HOME` 环境变量已...

    kafka可视化工具--kafkatool

    安装完成后,通过命令行界面输入“kafkatool”即可启动工具。 **最佳实践与注意事项**: - 在生产环境中使用Kafkatool时,确保了解操作的影响,避免误操作导致数据丢失。 - 定期更新Kafkatool至最新版本,以获取新...

    Kafka详细课程讲义

    5. 启动Kafka服务。 6. 创建主题(topics)并测试生产者和消费者。 使用Kafka时,可以通过命令行工具进行操作,如创建、删除主题,启动和停止消费者等。 **第 3 章 Kafka 架构深入** Kafka的核心架构由以下组件...

    kafka部署和使用详尽PDF

    集群启动和监控与单机部署类似,但需分别在每台服务器上启动Zookeeper和Kafka,确保所有节点都能正常通信并参与集群。 总结,这份PDF提供了从基础环境准备到Kafka服务启动的完整步骤,适合初学者和运维人员参考。...

    Kafka管理工具Kafka Tool

    **Kafka Tool:高效管理...总的来说,Kafka Tool是Kafka管理员和开发者的得力助手,它简化了与Kafka交互的过程,提高了工作效率,是管理复杂Kafka集群不可或缺的工具之一。无论是日常运维还是问题排查,都能从中受益。

    springboot 基于spring-kafka动态创建kafka消费者

    5. **运行与测试**:启动Spring Boot应用,当`kafka.consumer.enabled`设置为`true`时,消费者将开始监听指定的Kafka主题。你可以通过发送消息到该主题来测试消费者的运行情况。 以上就是基于Spring Boot和Spring ...

    Kafka Tool linux版本,适用于kafka0.11及以上

    7. **安全支持**:如果Kafka集群启用了SASL/SSL或Kerberos等安全机制,Kafka Tool也能很好地与之兼容,确保管理操作的安全性。 8. **命令行集成**:虽然Kafka Tool提供了一个直观的UI,但它也支持通过命令行执行...

    linux安装kafka教程

    使用脚本启动 Zookeeper 和 Kafka,可以使用以下命令: #!/bin/bash # 启动 Zookeeper /DATA/kafka/kafka_2.12-2.0.0/bin/zookeeper-server-start.sh /DATA/kafka/kafka_2.12-2.0.0/config/zookeeper.properties & ...

    介绍kafka及kafka集群安装

    6. **启动 Kafka**:使用 `kafka-server-start.sh` 命令启动 Kafka 服务。 7. **验证**:使用 Kafka 提供的命令工具 `kafka-topics.sh` 创建 Topic,`kafka-console-producer.sh` 和 `kafka-console-consumer.sh` ...

    jdk1.8+kafka3.2 linux版本

    安装Kafka主要包括解压、配置服务器属性(如server.properties)、创建数据目录、启动Zookeeper服务,然后启动Kafka服务。 在Linux环境下搭建Kafka,你需要修改`config/server.properties`文件,配置包括broker.id...

    kafka资源下载kafka_2.11-2.0.0.tgz

    - 启动Kafka Broker:`$KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties`。 - 创建主题并发布消息进行测试,验证安装是否成功。 #### 版本特性 Kafka 2.0.0版本主要引入了以下特性...

    Kafka Tool Mac版本,适用于kafka0.11及以上

    在Mac环境下,用户可以下载名为“kafkatool.dmg”的压缩包文件,双击安装后即可启动Kafka Tool。首次运行时,用户可能需要配置连接到Kafka集群的参数,如Bootstrap Servers、Zookeeper地址等。一旦设置完毕,就能...

    kafka2.3.0 linux版本

    6. **启动Kafka**: 使用Kafka的启动脚本启动服务器: ``` bin/kafka-server-start.sh config/server.properties ``` 7. **创建Topic**: 使用`kafka-topics.sh`工具创建一个Topic: ``` bin/kafka-topics.sh --...

    kafka-2.12-3.6.1.tgz

    Kafka 2.12-3.6.1在Linux环境中的部署和使用并不复杂,只需几个步骤即可完成基础配置和启动。然而,真正实现高可用、高性能的Kafka集群还需要深入理解和调整其内部参数,以及合理规划数据存储和网络通信策略。希望这...

    kafka-manager-2.0.0.2.zip

    Kafka Manager是由雅虎开发的一款针对Apache Kafka集群的开源Web管理工具。它的主要目标是提供一个用户友好的界面,使得Kafka...对于那些需要管理和监控多个Kafka集群的组织来说,Kafka Manager是一个不可或缺的工具。

    kafka-2.13-2.8.0

    2. **启动与停止**:启动Kafka服务需要启动Zookeeper,然后启动Kafka的Broker服务。 3. **创建主题**:使用kafka-topics.sh脚本创建主题,指定分区数量和副本数。 4. **监控与管理**:Kafka提供kafka-consumer-...

    在linux中搭建kafka集群

    10. 一旦Zookeeper集群成功启动,你就可以继续配置和启动Kafka服务器了,这个过程涉及到创建broker配置,设置broker.id,配置Zookeeper连接,以及启动`kafka-server-start.sh`脚本。 搭建Kafka集群是一个涉及多个...

Global site tag (gtag.js) - Google Analytics