文档章节

Kafka Eagle

China_OS
 China_OS
发布于 2017/08/30 15:16
字数 435
阅读 668
收藏 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
粉丝 413
博文 455
码字总数 512400
作品 0
静安
技术主管
私信 提问
加载中

评论(10)

凡尔

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

大佬我的页面打开怎么一篇空白呀,后端一堆错,
######################################
# 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

###################
大佬有解决吗?
China_OS
China_OS

引用来自“tingliu0724”的评论

你好,想跟你请教个问题:请问下kafka eagle是一定需要数据库吗?我现在linux系统上配置好了,也运行成功了,但是网页里面显示不出来?原因是由于我没有配置数据库吗?现在我已安装sqlit3,但是不知道还要如何配置或者初始化。
数据库是需要的,数据库也需要初始化,页面无法显示,日志中应该会有一些异常吧
tingliu0724
tingliu0724
你好,想跟你请教个问题:请问下kafka eagle是一定需要数据库吗?我现在linux系统上配置好了,也运行成功了,但是网页里面显示不出来?原因是由于我没有配置数据库吗?现在我已安装sqlit3,但是不知道还要如何配置或者初始化。
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
Apache Eagle:分布式实时 Hadoop 数据安全方案

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

oschina
2015/10/29
7.6K
7
sqlplus批量执行脚本日志输出

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

吕兵阳
2014/07/26
0
0
Apache 基金会宣布 Apache Eagle 成为顶级项目

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

王练
2017/01/10
5.2K
4
Hadoop 数据安全方案 - Apache Eagle

eBay公司隆重宣布正式向开源业界推出分布式实时安全监控引方案 - Apache Eagle ,该项目已正式加入Apache 称为孵化器项目。Apache Eagle提供一套高效分布式的流式策略引擎,具有高实时、可伸...

haoch
2015/10/28
0
0

没有更多内容

加载失败,请刷新页面

加载更多

KaliLinux常用服务配置教程DHCP服务工作流程

KaliLinux常用服务配置教程DHCP服务工作流程 DHCP服务工作流程如图1.1所示。 具体的工作流程如下所示: (1)DHCP客户端以广播的方式发出DHCP Discover报文。 (2)所有的DHCP服务器(DHCP ...

大学霸
9分钟前
0
0
Spring Junit单元测试配置

<dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>5.1.2.RELEASE</version></dependency><dependency> <group......

TonyTaotao
14分钟前
0
0
线程安全与非线程安全-个人理解

类的某个方法是线程安全的, 说明这个方法在并发执行中,从开始执行到执行完毕,都是同步的, 比如:之前做的并发数据导出,并发的查询数据库, 但是在写入excel的时候,需要做一个同步,因为...

Java搬砖工程师
16分钟前
1
0
如何提升JavaScript的任务效率?学会后教给你同事

本文由云+社区发表 一、概述 JavaScript 语言采用的是单线程模型,也就是说,所有任务只能在一个线程上完成,一次只能做一件事。前面的任务没做完,后面的任务只能等着。随着电脑计算能力的增...

腾讯云加社区
16分钟前
0
0
Hadoop运行在Kubernetes平台实践

Hadoop与Kubernetes就好像江湖里的两大绝世高手,一个是成名已久的长者,至今仍然名声远扬,一个则是初出茅庐的青涩少年,骨骼惊奇,不走寻常路,一出手便惊诧了整个武林。Hadoop与Kubernete...

微笑向暖wx
17分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部