文档章节

Kafka Eagle

China_OS
 China_OS
发布于 2017/08/30 15:16
字数 435
阅读 225
收藏 0
点赞 0
评论 7

        之前介绍过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
粉丝 400
博文 383
码字总数 483581
作品 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

###################
魅族屈跃辉:数据安全或成核心竞争力!

  【IT168 评论】时光荏苒,转瞬之间第九届DTCC中国数据库技术大会即将拉开帷幕,此时的你是否已经迫不及待?我知道,此时的对于第九届DTCC盛会一定是翘首以盼,但抱歉的是大会日期是万万不...

it168网站 ⋅ 05/04 ⋅ 0

降低开放式创新的壁垒 | 赢在 Apache系列之一

序 精英制、慈善机构、纯粹的个人志愿者、至今仍然是一个虚拟组织、拥有超过 350 个开源项目、有 3255 个提交者为 Apache 的项目做出了贡献...... Apache 的项目支撑了大半个互联网,Hadoop ...

开源社 ⋅ 06/08 ⋅ 0

美日机器人大战掌声后,MegaBots 资金烧尽赌上最后机会

美日机器人世纪之战落幕至今半年,原本打算筹办巨型机器人联赛的美国机器人团队 MegaBots,因众筹反应不佳被迫喊卡。稍早 MegaBots 共同创办人暨CEO Matt Oehrlein 透过影片沉痛坦言,公司正...

杨 安琪 ⋅ 04/18 ⋅ 0

各大厂分布式链路跟踪系统架构对比

随着互联网架构的扩张,分布式系统变得日趋复杂,越来越多的组件开始走向分布式化,如微服务、消息收发、分布式数据库、分布式缓存、分布式对象存储、跨域调用,这些组件共同构成了繁杂的分布...

james8888 ⋅ 04/19 ⋅ 0

你的数据化经营为何屡战屡败,118位CTO给出的7个管理经验

     大数据文摘作品   编译:傅一洋、笪洁琼、魏子敏   提升数据分析能力正成为企业数字化转型的当务之急。   成功的企业数字化案例显然有自己的共同点:   重视数据质量、重视...

大数据文摘 ⋅ 06/03 ⋅ 0

Spark RDD Map Reduce 基本操作

RDD是什么? RDD是Spark中的抽象数据结构类型,任何数据在Spark中都被表示为RDD。从编程的角度来看,RDD可以简单看成是一个数组。和普通数组的区别是,RDD中的数据是分区存储的,这样不同分区...

加米谷大数据 ⋅ 04/16 ⋅ 0

Ping不通不代表主机不在线!

局域网络中,测试客户机当前是否在线一般都是ping对方,返回TTL=XXX 就在线,返回Request timed out一般就“当做”它不在线。极少有人继续往下探究,直到确定对方是否在线。 其实Request tim...

日久不生情 ⋅ 2017/11/28 ⋅ 0

Apache 基金会宣布 Apache Eagle 成为顶级项目

2017年1月10日, 由超过350个开源项目及创新计划,全部由开发志愿者,治理志愿者及孵化志愿者组成的Apache软件基金会(ASF),宣布Apache Eagle已经从Apache孵化器项目毕业,正式升级成为顶级...

王练 ⋅ 2017/01/10 ⋅ 4

Apache Eagle:分布式实时 Hadoop 数据安全方案

摘要:日前,eBay公司隆重宣布正式向开源业界推出实时分布式Hadoop数据安全方案 - Apache Eagle,作为一套旨在提供高效分布式的流式策略引擎,并集成机器学习对用户行为建立Profile以实时智能...

oschina ⋅ 2015/10/29 ⋅ 7

【开源访谈】Apache Eagle 联合发起人陈浩:如何发起和维护开源项目

Apache Eagle是开源分布式实时Hadoop数据安全方案,支持数据行为实时监控,能立即监测出对敏感数据的访问或恶意的操作,并立即采取应对的措施。它是如何成为Apache 顶级开源项目的呢?在发起...

OSC源创君 ⋅ 2017/06/04 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

解决CentOS6、7,/etc/sysconfig/下没有iptables的问题

一、Centos 6版本解决办法: 1.任意运行一条iptables防火墙规则配置命令: iptables -P OUTPUT ACCEPT 2.对iptables服务进行保存: service iptables save 3.重启iptables服务: service ...

寰宇01 ⋅ 31分钟前 ⋅ 2

数据库备份和恢复

备份:mysqldump -u root -p 数据库>磁盘路径 恢复:mysql -u root -p 数据库<sql脚本的磁盘路径

anlve ⋅ 今天 ⋅ 0

发生了什么?Linus 又发怒了?

在一个 Linux 内核 4.18-rc1 的 Pull Request 中,开发者 Andy Shevchenko 表示其在对设备属性框架进行更新时,移除了 union 别名,这引发了 Linus 的暴怒。 这一次 Linus Torvalds 发怒的原...

问题终结者 ⋅ 今天 ⋅ 0

在树莓派上搭建一个maven仓库

在树莓派上搭建一个maven仓库 20180618 lambo init 项目说明 家里有台树莓派性能太慢。想搭建一个maven私服, 使用nexus或者 jfrog-artifactory 运行的够呛。怎么办呢,手写一个吧.所在这个...

林小宝 ⋅ 今天 ⋅ 0

Spring发展历程总结

转自与 https://www.cnblogs.com/RunForLove/p/4641672.html 目前很多公司的架构,从Struts2迁移到了SpringMVC。你有想过为什么不使用Servlet+JSP来构建Java web项目,而是采用SpringMVC呢?...

onedotdot ⋅ 今天 ⋅ 0

Python模块/包/库安装(6种方法)

Python模块/包/库安装(6种方法) 冰颖机器人 2016-11-29 21:33:26 一、方法1: 单文件模块 直接把文件拷贝到 $python_dir/Lib 二、方法2: 多文件模块,带setup.py 下载模块包(压缩文件zip...

cswangyx ⋅ 今天 ⋅ 0

零基础学习大数据人工智能,学习路线篇!系统规划大数据之路?

大数据处理技术怎么学习呢?首先我们要学习Python语言和Linux操作系统,这两个是学习大数据的基础,学习的顺序不分前后。 Python:Python 的排名从去年开始就借助人工智能持续上升,现在它已经...

董黎明 ⋅ 今天 ⋅ 0

openJdk和sun jdk的区别

使用过LINUX的人都应该知道,在大多数LINUX发行版本里,内置或者通过软件源安装JDK的话,都是安装的OpenJDK, 那么到底什么是OpenJDK,它与SUN JDK有什么关系和区别呢? 历史上的原因是,Ope...

jason_kiss ⋅ 今天 ⋅ 0

梳理

Redux 是 JavaScript 状态容器,提供可预测化的状态管理。 它是JS的状态容器,是一种解决问题的方式,所以即可以用于 react 也可以用于 vue。 需要理解其思想及实现方式。 应用中所有的 stat...

分秒 ⋅ 今天 ⋅ 0

Java 后台判断是否为ajax请求

/** * 是否是Ajax请求 * @param request * @return */public static boolean isAjax(ServletRequest request){return "XMLHttpRequest".equalsIgnoreCase(((HttpServletReques......

JavaSon712 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部