kafkajs - npm Package Compare versions

Comparing version 1.15.0-beta.3 to 1.15.0-beta.4

package.json

 {
   "name": "kafkajs",
-  "version": "1.15.0-beta.3",
+  "version": "1.15.0-beta.4",
   "description": "A modern Apache Kafka client for node.js",
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "be820c2b2da1ea0297ab173c91ead9c23fd5eef6",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...be820c2b2da1ea0297ab173c91ead9c23fd5eef6"
+    "sha": "7df9cee482829118f21d524246b492773b1718ae",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...7df9cee482829118f21d524246b492773b1718ae"
   }
 }

src/consumer/consumerGroup.js

@@ -12,3 +12,3 @@ const flatten = require('../utils/flatten')
 const {
-  events: { HEARTBEAT, CONNECT },
+  events: { HEARTBEAT, CONNECT, RECEIVED_UNSUBSCRIBED_TOPICS },
 } = require('./instrumentationEvents')
@@ -189,2 +189,3 @@ const { MemberAssignment } = require('./assignerProtocol')
       decodedMemberAssignment != null ? decodedMemberAssignment.assignment : {}
+
     this.logger.debug('Received assignment', {
@@ -201,3 +202,3 @@ groupId,
     if (topicsNotSubscribed.length > 0) {
-      this.logger.warn('Consumer group received unsubscribed topics', {
+      const payload = {
         groupId,
@@ -209,2 +210,7 @@ generationId,
         topicsNotSubscribed,
+      }
+
+      this.instrumentationEmitter.emit(RECEIVED_UNSUBSCRIBED_TOPICS, payload)
+      this.logger.warn('Consumer group received unsubscribed topics', {
+        ...payload,
         helpUrl: websiteUrl(
@@ -211,0 +217,0 @@ 'docs/faq',

src/consumer/instrumentationEvents.js

@@ -18,2 +18,3 @@ const swapObject = require('../utils/swapObject')
   CRASH: consumerType('crash'),
+  RECEIVED_UNSUBSCRIBED_TOPICS: consumerType('received_unsubscribed_topics'),
   REQUEST: consumerType(networkEvents.NETWORK_REQUEST),
@@ -20,0 +21,0 @@ REQUEST_TIMEOUT: consumerType(networkEvents.NETWORK_REQUEST_TIMEOUT),

types/index.d.ts

@@ -601,2 +601,3 @@ /// <reference types="node" />
   CRASH: 'consumer.crash'
+  RECEIVED_UNSUBSCRIBED_TOPICS: 'consumer.received_unsubscribed_topics'
   REQUEST: 'consumer.network.request'
@@ -658,2 +659,10 @@ REQUEST_TIMEOUT: 'consumer.network.request_timeout'
 }>
+export type ConsumerReceivedUnsubcribedTopicsEvent = InstrumentationEvent<{
+  groupId: string
+  generationId: number
+  memberId: string
+  assignedTopics: string[]
+  topicsSubscribed: string[]
+  topicsNotSubscribed: string[]
+}>
 
@@ -660,0 +669,0 @@ export interface OffsetsByTopicPartition {

No alert changes

Improved metrics

Total package byte prevSize

597049

0.09%

Lines of code

17606

0.08%

No dependency changes