Kafka Eagle
博客专区 > China_OS 的博客 > 博客详情
Kafka Eagle
China_OS 发表于2个月前
Kafka Eagle
  • 发表于 2个月前
  • 阅读 66
  • 收藏 0
  • 点赞 0
  • 评论 7

腾讯云 十分钟定制你的第一个小程序>>>   

摘要: Kafka Eagle monitor

        之前介绍过kafka manager的部署,这个东西在kafka管理里面是出现的最早的,用的人也比较多,不过有个大问题就是没安全认证,在kafka manager上你可以随意的创建删除topic,这要是放到一个公共环境中,很可能出问题的。当然也有一些不错的kafka管理平台,功能很全高大上,很可惜人家没开源,都在各个大厂中隐藏着。在github中偶然发现了一个看起来还凑活的项目(Kafka Eagle),自己拉回来再扩展扩展还是不错的。本文就是Kafka Eagle的试用。

下载

    github

git clone https://github.com/smartloli/kafka-eagle.git

    直接下载

cd /opt/programs
wget 'https://coding.net/u/smartloli/p/kafka-eagle-bin/git/raw/master/kafka-eagle-web-1.1.8-bin.tar.gz'

        ps:作者提供了编译好的,那必须直接下载了

部署

cd /opt/programs
tar zxvf kafka-eagle-web-1.1.8-bin.tar.gz
mv kafka-eagle-web-1.1.8 kafka_eagle

调整配置

    调整system-config.properties

kafka.eagle.zk.cluster.alias=prd-ops,prd-dba
prd-ops.zk.list=ip:port,ip:port,ip:port
prd-dba.zk.list=ip:port,ip:port,ip:port
kafka.zk.limit.size=25
kafka.eagle.webui.port=8048
kafka.eagle.offset.storage=kafka
kafka.eagle.mail.enable=true
kafka.eagle.mail.sa=alert_sa
kafka.eagle.mail.username=xxx@126.com
kafka.eagle.mail.password=xxx
kafka.eagle.mail.server.host=mail.126.com
kafka.eagle.mail.server.port=25
kafka.eagle.topic.token=keadmin
kafka.eagle.sasl.enable=false
kafka.eagle.sasl.protocol=SASL_PLAINTEXT
kafka.eagle.sasl.mechanism=PLAIN
kafka.eagle.sasl.client=/opt/programs/kafka_eagle/conf/kafka_client_jaas.conf
kafka.eagle.driver=com.mysql.jdbc.Driver
kafka.eagle.url=jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
kafka.eagle.username=root
kafka.eagle.password=yyy

    调整ke.sh启动脚本

# add env
export JAVA_HOME=/opt/programs/jdk1.8.0_77
export PATH=$PATH:$JAVA_HOME/bin
export KE_HOME=/opt/programs/kafka_eagle
export PATH=$PATH:$KE_HOME/bin

    初始化ke DB库

mysql -uroot -h127.0.0.1 -p ke< sql/ke.sql

        ps:注意要是有mysql5.5以上版本,如果是5.5以下版本,ke.sql里面的建表语句的CHARSET=utf8mb4要调整成CHARSET=utf8

启动

cd /opt/programs/kafka_eagle
./bin/ke.sh start

试用

    首页

    速率

后记

    界面看起来不错,功能相比kafka manager有点单一,不过有个官方文档还不错

 

标签: kafka monitor
共有 人打赏支持
粉丝 389
博文 376
码字总数 478808
评论 (7)
大大的微笑
大佬我的页面打开怎么一篇空白呀,后端一堆错,
######################################
# multi zookeeper&kafka cluster list
######################################
kafka.eagle.zk.cluster.alias=cluster1
cluster1.zk.list=127.0.0.1:2181
#cluster2.zk.list=xdn10:2181,xdn11:2181,xdn12:2181

######################################
# zk client thread limit
######################################
kafka.zk.limit.size=25

######################################
# kafka eagle webui port
######################################
kafka.eagle.webui.port=8048

######################################
# kafka offset storage
######################################
kafka.eagle.offset.storage=kafka

######################################
# alarm email configure
######################################
#kafka.eagle.mail.enable=true
#kafka.eagle.mail.sa=alert_sa
#kafka.eagle.mail.username=alert_sa@163.com
#kafka.eagle.mail.password=mqslimczkdqabbbg
#kafka.eagle.mail.server.host=smtp.163.com
#kafka.eagle.mail.server.port=25

###################
大大的微笑
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/create/success],methods=[GET],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.s
uccessView(javax.servlet.http.HttpSession)
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/create/failed],methods=[GET],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.fa
iledView(javax.servlet.http.HttpSession)
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/add/form],methods=[POST],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.alarmA
ddForm(javax.
China_OS

引用来自“大大的微笑”的评论

2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/create/success],methods=[GET],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.s
uccessView(javax.servlet.http.HttpSession)
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/create/failed],methods=[GET],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.fa
iledView(javax.servlet.http.HttpSession)
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/add/form],methods=[POST],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.alarmA
ddForm(javax.
INFO错误没用,贴ERROR的
大大的微笑

引用来自“大大的微笑”的评论

2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/create/success],methods=[GET],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.s
uccessView(javax.servlet.http.HttpSession)
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/create/failed],methods=[GET],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.fa
iledView(javax.servlet.http.HttpSession)
2017-10-10 17:37:32 INFO [RequestMappingHandlerMapping.localhost-startStop-1] - Mapped "{[/alarm/add/form],methods=[POST],params=[],headers=[],consumes=[],produces=[],custom=[]}" onto public org.springframework.web.servlet.ModelAndView org.smartloli.kafka.eagle.web.controller.AlarmController.alarmA
ddForm(javax.

引用来自“China_OS”的评论

INFO错误没用,贴ERROR的
[2017-10-10 17:07:11] SimpleConsumer.ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-1 - INFO - Reconnect due to error:
java.nio.channels.ClosedChannelException
  at kafka.network.BlockingChannel.send(BlockingChannel.scala:110)
  at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:85)
  at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:83)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:132)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:132)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:132)
  at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:131)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:131)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:131)
  at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
  at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:130)
  at kafka.consumer.ConsumerFetcherThread.fetch(ConsumerFetcherThread.scala:111)
  at kafka.consumer.ConsumerFetcherThread.fetch(ConsumerFetcherThread.scala:31)
  at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:118)
  at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
  at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2017-10-10 17:07:11] ConsumerFetcherManager.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - [ConsumerFetcherManager-1507626330330] Added fetcher for partitions ArrayBuffer([__consumer_offsets-38, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-8, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-2, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-35, initOffset 29215 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-5, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-32, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-29, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-23, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-26, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-20, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-17, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-44, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-47, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-14, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-41, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] , [__consumer_offsets-11, initOffset 0 to broker BrokerEndPoint(1,localhost,9092)] )
[2017-10-10 17:07:11] ConsumerFetcherThread.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-3], Shutting down
[2017-10-10 17:07:11] ConsumerFetcherThread.ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-3 - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-3], Stopped
[2017-10-10 17:07:11] ConsumerFetcherThread.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-3], Shutdown completed
[2017-10-10 17:07:11] ConsumerFetcherThread.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-2], Shutting down
[2017-10-10 17:07:11] ConsumerFetcherThread.ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-2 - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-2], Stopped
[2017-10-10 17:07:11] ConsumerFetcherThread.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-2], Shutdown completed
[2017-10-10 17:07:11] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Verifying properties
[2017-10-10 17:07:11] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Property client.id is overridden to kafka.eagle.system.group
[2017-10-10 17:07:11] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Property metadata.broker.list is overridden to localhost:9092,localhost:9093,localhost:9094
[2017-10-10 17:07:11] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Property request.timeout.ms is overridden to 30000
[2017-10-10 17:07:11] ClientUtils$.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Fetching metadata from broker BrokerEndPoint(1,localhost,9092) with correlation id 3 for 1 topic(s) Set(__consumer_offsets)
[2017-10-10 17:07:11] SyncProducer.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Connected to localhost:9092 for producing
[2017-10-10 17:07:11] SyncProducer.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Disconnecting from localhost:9092
[2017-10-10 17:07:11] ConsumerFetcherThread.ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-3 - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-3], Starting
[2017-10-10 17:07:11] ConsumerFetcherThread.ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-2 - INFO - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-2], Starting
[2017-10-10 17:07:11] ConsumerFetcherManager.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - [ConsumerFetcherManager-1507626330330] Added fetcher for partitions ArrayBuffer([__consumer_offsets-49, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-27, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-16, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-19, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-13, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-46, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-24, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-43, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-21, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-10, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-37, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-48, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-40, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-18, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-7, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-34, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-45, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-15, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-4, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-42, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-31, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-9, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-12, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-1, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-28, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-6, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-39, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-36, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-3, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-25, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-30, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-22, initOffset 0 to broker BrokerEndPoint(3,localhost,9094)] , [__consumer_offsets-33, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] , [__consumer_offsets-0, initOffset 0 to broker BrokerEndPoint(2,localhost,9093)] )
[2017-10-10 17:07:41] ConsumerFetcherThread.ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-1 - WARN - [ConsumerFetcherThread-kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-0-1], Error in fetch kafka.consumer.ConsumerFetcherThread$FetchRequest@277c948c
java.net.SocketTimeoutException
  at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:229)
  at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
  at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
  at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:81)
  at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:129)
  at kafka.network.BlockingChannel.receive(BlockingChannel.scala:120)
  at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:99)
  at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:83)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SimpleConsumer.scala:132)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:132)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1$$anonfun$apply$mcV$sp$1.apply(SimpleConsumer.scala:132)
  at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply$mcV$sp(SimpleConsumer.scala:131)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:131)
  at kafka.consumer.SimpleConsumer$$anonfun$fetch$1.apply(SimpleConsumer.scala:131)
  at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33)
  at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:130)
  at kafka.consumer.ConsumerFetcherThread.fetch(ConsumerFetcherThread.scala:111)
  at kafka.consumer.ConsumerFetcherThread.fetch(ConsumerFetcherThread.scala:31)
  at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:118)
  at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
  at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
[2017-10-10 17:07:41] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Verifying properties
[2017-10-10 17:07:41] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Property client.id is overridden to kafka.eagle.system.group
[2017-10-10 17:07:41] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Property metadata.broker.list is overridden to localhost:9092,localhost:9093,localhost:9094
[2017-10-10 17:07:41] VerifiableProperties.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Property request.timeout.ms is overridden to 30000
[2017-10-10 17:07:41] ClientUtils$.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Fetching metadata from broker BrokerEndPoint(2,localhost,9093) with correlation id 4 for 1 topic(s) Set(__consumer_offsets)
[2017-10-10 17:07:41] SyncProducer.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Connected to localhost:9093 for producing
[2017-10-10 17:07:41] SyncProducer.kafka.eagle.system.group_xiaozhengwei-PC-1507626330199-fdede7e3-leader-finder-thread - INFO - Disconnecting from localhost:9093
[2017-10-10 17:07:41] SimpleConsumer.ConsumerFet 麻烦大佬看下,一直都是这个错
大大的微笑
[2017-10-10 17:05:29] MySqlStoragePlugin.Thread-56 - ERROR - Create mysql connection has error address[127.0.0.1:3306\ke],username[root],password123,msg is Cannot load connection class because of underlying exception: 'java.lang.NumberFormatException: For input string: "3306\ke"'.
[2017-10-10 17:05:30] MySqlStoragePlugin.Thread-63 - ERROR - Create mysql connection has error address[127.0.0.1:3306\ke],username[root],password123,msg is Cannot load connection class because of underlying exception: 'java.lang.NumberFormatException: For input string: "3306\ke"'.
[2017-10-10 17:10:00] OffsetsQuartz.org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-1 - ERROR - Quartz statistics offset has error,msg is null
[2017-10-10 17:10:01] Mx4jServiceImpl.org.springframework.scheduling.quartz.SchedulerFactoryBean#1_Worker-1 - ERROR - JMX service url[localhost:-1] create has error,msg is Failed to retrieve RMIServer stub: javax.naming.ServiceUnavailableException [Root exception is
大大的微笑
还有就是他这里怎么会出现转换呢, jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
China_OS

引用来自“大大的微笑”的评论

还有就是他这里怎么会出现转换呢, jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
这个后端依赖数据库的,需要你先初始化数据库才能使用的,mysql://127.0.0.1:3306 这个是你的mysql地址,看看你在哪里安装的
×
China_OS
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: