文档章节

Kafka Eagle

China_OS
 China_OS
发布于 2017/08/30 15:16
字数 435
阅读 378
收藏 0

        之前介绍过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有点单一,不过有个官方文档还不错

 

© 著作权归作者所有

共有 人打赏支持
China_OS
粉丝 412
博文 451
码字总数 510295
作品 0
静安
技术主管
加载中

评论(7)

China_OS
China_OS

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

还有就是他这里怎么会出现转换呢, jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
这个后端依赖数据库的,需要你先初始化数据库才能使用的,mysql://127.0.0.1:3306 这个是你的mysql地址,看看你在哪里安装的
大大的微笑
大大的微笑
还有就是他这里怎么会出现转换呢, jdbc:mysql://127.0.0.1:3306/ke?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull
大大的微笑
大大的微笑
[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
大大的微笑
大大的微笑

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

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 麻烦大佬看下,一直都是这个错
China_OS
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.
大大的微笑
大大的微笑
大佬我的页面打开怎么一篇空白呀,后端一堆错,
######################################
# 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

###################
Kafka监控系统Kafka Eagle剖析

1.概述 最近有同学留言反馈了使用Kafka监控工具Kafka Eagle的一些问题,这里笔者特意整理了这些问题。并且希望通过这篇博客来解答这些同学的在使用Kafka Eagle的时候遇到的一些困惑,同时也给...

哥不是小萝莉
07/27
0
0
sqlplus批量执行脚本日志输出

spool d:eagle2201459init.log; set feedback off; set define off; prompt -----初始化数据 start--- @D :projectsEagleV204Codev2.0eagle2resourcesdatabasefullcoccoc-initialize.sql @D ......

吕兵阳
2014/07/26
0
0
Eagle 自带爬虫功能的图片数据库

用你喜欢的方式,管理你喜欢的图片 Eagle是一款拥有爬虫功能图片数据库,支持批量爬取花瓣网图片 自动识别图片色调, 支持颜色查找! 同时能对图片进行形状查找, 来源查找, 尺寸查找等 能在任何环...

木子昭
07/17
0
0
Never Call Virtual Functions during Constructio...

代码 1. java class Bird { public Bird() {show();} public void show() {System.out.println("hey, I'm a bird.");}} class Eagle extends Bird {private String name = "littleEgale"; pu......

coda
2011/11/11
0
0
Altium Designer 14.1.5 Build 30772

Altium Designer 14.1.5 Build 30772 CAX/EDA Sinapse 2个月前 (12-08) 5593浏览 3评论 智能系统设计自动化的全球领导者及3D PCB 设计解决方案(Altium Designer)和嵌入软件开发(TASKING)...

江河海流
2014/02/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

django rest framework 外键序列化方法与问题总结

django rest framework 外键序列化方法与问题总结 当借口中需要出现一对多关系的时候,我们可以用rest_framwork的序列化功能来处理,代码如下. # models.pyfrom django.db import modelscl...

_Change_
昨天
1
0
SingleNumber136 leetCode

Given a non-empty array of integers, every element appears twice except for one. Find that single one. Note: Your algorithm should have a linear runtime complexity. Could you im......

woshixin
昨天
1
0
String ,  StringBuffer ,  StringBuilder的区别

String , StringBuffer , StringBuilder的区别 String 首先,String 是用来表示一个字符串常量的,它是一个不可变对象,意味着,一旦我们创建了某个字符串之后,就不能再改变它的值了,我们可...

tsmyk0715
昨天
3
0
区块链100讲:UTXO 和 Account 模型对比

在当前区块链世界中,主要有两种记录保存方式,UTXO 模式(Unspent Transaction Output) 和 Account 模式。Bitcoin 采用的是 UTXO 模型,Ethereum 采用的 Account 模型,同样 CITA 也采用了 ...

HiBlock
昨天
1
0
Vue中路由管理器Vue Router使用介绍(三)

一、路由定义添加动态参数定义 1.路由定义项,使用:xx 方式 定义动态参数 { path:'/user/:id/:name', name:'user', component:()=>import('./views/User.vue') ...

tianma3798
昨天
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部