File tree 4 files changed +45
-14
lines changed
4 files changed +45
-14
lines changed Original file line number Diff line number Diff line change 1
1
{
2
2
"kafka" : {
3
3
"zkConnect" : " 192.168.33.10:2181" ,
4
- "producerSeed" : " 0x9747b28c" ,
5
- "clientId" : {
4
+ "producerSeed" : " 0x9747b28c" ,
5
+ "clientId" : {
6
6
"socket" : " kafka-socket-proxy" ,
7
7
"http" : " kafka-http-proxy"
8
8
},
13
13
},
14
14
"logging" : {
15
15
"logName" : " kafka-http-proxy" ,
16
- "level" : " trace"
16
+ "stdout" : {
17
+ "level" : " trace" ,
18
+ "enabled" : true
19
+ },
20
+ "file" : {
21
+ "path" : " ./kafka-http-proxy.log" ,
22
+ "level" : " trace" ,
23
+ "enabled" : false
24
+ }
17
25
},
18
26
"cache" : {
19
27
"timeout" : 600
Original file line number Diff line number Diff line change 1
1
{
2
- "kafka" : {
3
- "zkConnect" : " 192.168.33.10:2181"
2
+ "kafka" : {
3
+ "zkConnect" : " 192.168.33.10:2181"
4
4
},
5
5
"logging" : {
6
- "level" : " debug"
6
+ "stdout" : {
7
+ "level" : " debug"
8
+ },
9
+ "file" : {
10
+ "level" : " debug" ,
11
+ "enabled" : false
12
+ }
7
13
}
8
14
}
Original file line number Diff line number Diff line change 1
1
var bunyan = require ( 'bunyan' ) ;
2
2
var config = require ( './config' ) ;
3
+ var PrettyStream = require ( 'bunyan-prettystream' ) ;
4
+
5
+ var prettyStdOut = new PrettyStream ( ) ;
6
+ prettyStdOut . pipe ( process . stdout ) ;
3
7
4
- var logger = new bunyan . createLogger ( {
5
- name : config . logging . logName ,
6
- src :true ,
7
- streams : [
8
- {
9
- level : config . logging . level ,
10
- stream : process . stdout
11
- } ]
8
+ var streams = [ ] ;
9
+ if ( config . logging . stdout && config . logging . stdout . enabled ) {
10
+ streams . push ( {
11
+ level : config . logging . stdout . level ,
12
+ type : 'raw' ,
13
+ stream : prettyStdOut
14
+ } ) ;
15
+ }
16
+ if ( config . logging . file && config . logging . file . enabled ) {
17
+ streams . push ( {
18
+ level : config . logging . file . level ,
19
+ path : config . logging . file . path ,
20
+ type : 'file'
12
21
} ) ;
22
+ }
23
+
24
+ var logger = new bunyan . createLogger ( {
25
+ name : config . logging . logName ,
26
+ src : true ,
27
+ streams : streams
28
+ } ) ;
13
29
14
30
module . exports = {
15
31
logger : logger ,
Original file line number Diff line number Diff line change 7
7
"dependencies" : {
8
8
"body-parser" : " ^1.14.1" ,
9
9
"bunyan" : " ^1.5.1" ,
10
+ "bunyan-prettystream" : " ^0.1.3" ,
10
11
"config-node" : " ^1.2.2" ,
11
12
"express" : " ^4.13.3" ,
12
13
"kafka-node" : " https://github.com/hoppity/kafka-node/tarball/master" ,
You can’t perform that action at this time.
0 commit comments