Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

kafka-avro

Package Overview
Dependencies
Maintainers
1
Versions
46
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

kafka-avro - npm Package Compare versions

Comparing version 0.4.0 to 0.4.1

4

lib/kafka-consumer.js

@@ -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()

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc