kafka-avro
Advanced tools
Comparing version 0.4.0 to 0.4.1
@@ -38,4 +38,4 @@ /** | ||
consumer.on('event.log', function(log) { | ||
log.info('node-rdkafka log:', log); | ||
consumer.on('event.log', function(logMessage) { | ||
log.info('node-rdkafka log:', logMessage); | ||
}); | ||
@@ -42,0 +42,0 @@ |
{ | ||
"name": "kafka-avro", | ||
"version": "0.4.0", | ||
"version": "0.4.1", | ||
"main": "./lib/kafka-avro", | ||
@@ -5,0 +5,0 @@ "description": "Node.js bindings for librdkafka with Avro schema serialization.", |
@@ -177,8 +177,14 @@ # kafka-avro | ||
### Helper Methods | ||
The KafkaAvro instance also provides the following methods: | ||
### Logging | ||
The Kafka Avro library logs messages using the [Bunyan logger](https://github.com/trentm/node-bunyan/). | ||
#### KafkaAvro.getLogger() | ||
> **WARNING** The logger will not emit any messages as it was expected, there is an [open issue on Bunyan's repository](https://github.com/trentm/node-bunyan/issues/479) pending a solution on this. So no logging for now. | ||
> **NOTICE** This is a **static method** on the `KafkaAvro` constructor, not the instance. Therefore there is a single logger instance for the whole runtime. | ||
@@ -196,3 +202,3 @@ | ||
type: 'stream', | ||
stream: fmr({ | ||
stream: fmt({ | ||
outputMode: 'short', | ||
@@ -207,2 +213,4 @@ levelInString: true, | ||
### Helper Methods | ||
#### kafkaAvro.serialize(type, schemaId, value) | ||
@@ -241,2 +249,4 @@ | ||
- **v0.4.1**, *10 Feb 2017* | ||
- Fixed relaying Kafka consumer logs. | ||
- **v0.4.0**, *03 Feb 2017* | ||
@@ -243,0 +253,0 @@ - Refactored all logging to use a central Bunyan logger that is now provided through the static method `KafkaAvro.getLogger()`. |
@@ -55,3 +55,3 @@ /* | ||
level: 'debug', | ||
}); | ||
}, 'debug'); | ||
@@ -72,3 +72,3 @@ this.timeout(180000); // wait up to 3' for the SR to come up | ||
testLib.log.info('test.beforeEach 2: Invoking kafkaAvro.init()...', kafkaAvro.init); | ||
testLib.log.info('test.beforeEach 2: Invoking kafkaAvro.init()...'); | ||
@@ -75,0 +75,0 @@ return kafkaAvro.init() |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
47664
276