Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
caopu16
whatsmars
提交
547a5310
W
whatsmars
项目概览
caopu16
/
whatsmars
与 Fork 源项目一致
Fork自
武汉红喜 / whatsmars
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
W
whatsmars
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
547a5310
编写于
8月 27, 2019
作者:
武汉红喜
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
whatsmars-mq-kafka-server
上级
5841ed79
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
125 addition
and
7 deletion
+125
-7
pom.xml
pom.xml
+7
-0
whatsmars-mq/pom.xml
whatsmars-mq/pom.xml
+1
-0
whatsmars-mq/whatsmars-mq-kafka-server/pom.xml
whatsmars-mq/whatsmars-mq-kafka-server/pom.xml
+26
-0
whatsmars-mq/whatsmars-mq-kafka-server/src/main/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
...rc/main/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
+0
-0
whatsmars-mq/whatsmars-mq-kafka-server/src/main/resources/log4j.properties
...smars-mq-kafka-server/src/main/resources/log4j.properties
+91
-0
whatsmars-mq/whatsmars-mq-kafka-server/src/main/resources/server.properties
...mars-mq-kafka-server/src/main/resources/server.properties
+0
-0
whatsmars-mq/whatsmars-mq-kafka/pom.xml
whatsmars-mq/whatsmars-mq-kafka/pom.xml
+0
-7
未找到文件。
pom.xml
浏览文件 @
547a5310
...
...
@@ -50,6 +50,7 @@
<hessian.version>
4.0.7
</hessian.version>
<jackson.version>
2.9.9
</jackson.version>
<javassist.version>
3.24.1-GA
</javassist.version>
<log4j.version>
1.2.16
</log4j.version>
<mybatis.version>
3.4.5
</mybatis.version>
<mybatis-spring.version>
1.3.1
</mybatis-spring.version>
<rocketmq.version>
4.5.1
</rocketmq.version>
...
...
@@ -124,6 +125,12 @@
<version>
${commons-dbcp.version}
</version>
</dependency>
<dependency>
<groupId>
log4j
</groupId>
<artifactId>
log4j
</artifactId>
<version>
${log4j.version}
</version>
</dependency>
<dependency>
<groupId>
com.alibaba
</groupId>
<artifactId>
fastjson
</artifactId>
...
...
whatsmars-mq/pom.xml
浏览文件 @
547a5310
...
...
@@ -26,6 +26,7 @@
<module>
whatsmars-mq-rocketmq-tools
</module>
<module>
whatsmars-mq-rocketmq-spring
</module>
<module>
whatsmars-otter-mq
</module>
<module>
whatsmars-mq-kafka-server
</module>
</modules>
<dependencyManagement>
...
...
whatsmars-mq/whatsmars-mq-kafka-server/pom.xml
0 → 100644
浏览文件 @
547a5310
<?xml version="1.0" encoding="UTF-8"?>
<project
xmlns=
"http://maven.apache.org/POM/4.0.0"
xmlns:xsi=
"http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation=
"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
>
<parent>
<artifactId>
whatsmars-mq
</artifactId>
<groupId>
org.hongxi
</groupId>
<version>
Rocket.S7
</version>
</parent>
<modelVersion>
4.0.0
</modelVersion>
<artifactId>
whatsmars-mq-kafka-server
</artifactId>
<dependencies>
<dependency>
<groupId>
org.apache.kafka
</groupId>
<artifactId>
kafka_2.11
</artifactId>
<version>
2.0.1
</version>
</dependency>
<dependency>
<groupId>
org.springframework.boot
</groupId>
<artifactId>
spring-boot-starter-logging
</artifactId>
</dependency>
</dependencies>
</project>
\ No newline at end of file
whatsmars-mq/whatsmars-mq-kafka
/src/test
/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
→
whatsmars-mq/whatsmars-mq-kafka
-server/src/main
/java/org/hongxi/whatsmars/kafka/KafkaStartup.java
浏览文件 @
547a5310
文件已移动
whatsmars-mq/whatsmars-mq-kafka-server/src/main/resources/log4j.properties
0 → 100644
浏览文件 @
547a5310
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
# Unspecified loggers and loggers with additivity=true output to server.log and stdout
# Note that INFO only applies to unspecified loggers, the log level of the child logger is used otherwise
log4j.rootLogger
=
INFO, stdout, kafkaAppender
log4j.appender.stdout
=
org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout
=
org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern
=
[%d] %p %m (%c)%n
log4j.appender.kafkaAppender
=
org.apache.log4j.DailyRollingFileAppender
log4j.appender.kafkaAppender.DatePattern
=
'.'yyyy-MM-dd-HH
log4j.appender.kafkaAppender.File
=
${kafka.logs.dir}/server.log
log4j.appender.kafkaAppender.layout
=
org.apache.log4j.PatternLayout
log4j.appender.kafkaAppender.layout.ConversionPattern
=
[%d] %p %m (%c)%n
log4j.appender.stateChangeAppender
=
org.apache.log4j.DailyRollingFileAppender
log4j.appender.stateChangeAppender.DatePattern
=
'.'yyyy-MM-dd-HH
log4j.appender.stateChangeAppender.File
=
${kafka.logs.dir}/state-change.log
log4j.appender.stateChangeAppender.layout
=
org.apache.log4j.PatternLayout
log4j.appender.stateChangeAppender.layout.ConversionPattern
=
[%d] %p %m (%c)%n
log4j.appender.requestAppender
=
org.apache.log4j.DailyRollingFileAppender
log4j.appender.requestAppender.DatePattern
=
'.'yyyy-MM-dd-HH
log4j.appender.requestAppender.File
=
${kafka.logs.dir}/kafka-request.log
log4j.appender.requestAppender.layout
=
org.apache.log4j.PatternLayout
log4j.appender.requestAppender.layout.ConversionPattern
=
[%d] %p %m (%c)%n
log4j.appender.cleanerAppender
=
org.apache.log4j.DailyRollingFileAppender
log4j.appender.cleanerAppender.DatePattern
=
'.'yyyy-MM-dd-HH
log4j.appender.cleanerAppender.File
=
${kafka.logs.dir}/log-cleaner.log
log4j.appender.cleanerAppender.layout
=
org.apache.log4j.PatternLayout
log4j.appender.cleanerAppender.layout.ConversionPattern
=
[%d] %p %m (%c)%n
log4j.appender.controllerAppender
=
org.apache.log4j.DailyRollingFileAppender
log4j.appender.controllerAppender.DatePattern
=
'.'yyyy-MM-dd-HH
log4j.appender.controllerAppender.File
=
${kafka.logs.dir}/controller.log
log4j.appender.controllerAppender.layout
=
org.apache.log4j.PatternLayout
log4j.appender.controllerAppender.layout.ConversionPattern
=
[%d] %p %m (%c)%n
log4j.appender.authorizerAppender
=
org.apache.log4j.DailyRollingFileAppender
log4j.appender.authorizerAppender.DatePattern
=
'.'yyyy-MM-dd-HH
log4j.appender.authorizerAppender.File
=
${kafka.logs.dir}/kafka-authorizer.log
log4j.appender.authorizerAppender.layout
=
org.apache.log4j.PatternLayout
log4j.appender.authorizerAppender.layout.ConversionPattern
=
[%d] %p %m (%c)%n
# Change the line below to adjust ZK client logging
log4j.logger.org.apache.zookeeper
=
INFO
# Change the two lines below to adjust the general broker logging level (output to server.log and stdout)
log4j.logger.kafka
=
INFO
log4j.logger.org.apache.kafka
=
INFO
# Change to DEBUG or TRACE to enable request logging
log4j.logger.kafka.request.logger
=
WARN, requestAppender
log4j.additivity.kafka.request.logger
=
false
# Uncomment the lines below and change log4j.logger.kafka.network.RequestChannel$ to TRACE for additional output
# related to the handling of requests
#log4j.logger.kafka.network.Processor=TRACE, requestAppender
#log4j.logger.kafka.server.KafkaApis=TRACE, requestAppender
#log4j.additivity.kafka.server.KafkaApis=false
log4j.logger.kafka.network.RequestChannel$=WARN,
requestAppender
log4j.additivity.kafka.network.RequestChannel$=false
log4j.logger.kafka.controller
=
TRACE, controllerAppender
log4j.additivity.kafka.controller
=
false
log4j.logger.kafka.log.LogCleaner
=
INFO, cleanerAppender
log4j.additivity.kafka.log.LogCleaner
=
false
log4j.logger.state.change.logger
=
TRACE, stateChangeAppender
log4j.additivity.state.change.logger
=
false
# Access denials are logged at INFO level, change to DEBUG to also log allowed accesses
log4j.logger.kafka.authorizer.logger
=
INFO, authorizerAppender
log4j.additivity.kafka.authorizer.logger
=
false
whatsmars-mq/whatsmars-mq-kafka
/src/test
/resources/server.properties
→
whatsmars-mq/whatsmars-mq-kafka
-server/src/main
/resources/server.properties
浏览文件 @
547a5310
文件已移动
whatsmars-mq/whatsmars-mq-kafka/pom.xml
浏览文件 @
547a5310
...
...
@@ -23,13 +23,6 @@
<groupId>
org.springframework.kafka
</groupId>
<artifactId>
spring-kafka
</artifactId>
</dependency>
<dependency>
<groupId>
org.apache.kafka
</groupId>
<artifactId>
kafka_2.11
</artifactId>
<version>
2.0.1
</version>
<scope>
test
</scope>
</dependency>
</dependencies>
<build>
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录