Skip to content

Commit

Permalink
add newlines
Browse files Browse the repository at this point in the history
  • Loading branch information
Robin Fehr committed Jul 12, 2022
1 parent 9a7e699 commit a84add1
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
3 changes: 2 additions & 1 deletion docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -47,4 +47,5 @@ services:
KAFKA_CLUSTERS_0_ZOOKEEPER: zookeeper:2181
networks:
localnet:
attachable: true
attachable: true

9 changes: 5 additions & 4 deletions lib/kafka-consumer.js
Original file line number Diff line number Diff line change
Expand Up @@ -92,9 +92,9 @@ function KafkaConsumer(conf, topicConf) {

// If rebalance is undefined we don't want any part of this
if (onRebalance && typeof onRebalance === "boolean") {
conf.rebalance_cb =
conf["partition.assignment.strategy"] === "cooperative-sticky" ?
cooperativeRebalanceCallback.bind(this) :
conf.rebalance_cb =
conf["partition.assignment.strategy"] === "cooperative-sticky" ?
cooperativeRebalanceCallback.bind(this) :
eagerRebalanceCallback.bind(this);
} else if (onRebalance && typeof onRebalance === "function") {
/*
Expand Down Expand Up @@ -724,4 +724,5 @@ module.exports = {
KafkaConsumer: KafkaConsumer,
eagerRebalanceCallback: eagerRebalanceCallback,
cooperativeRebalanceCallback: cooperativeRebalanceCallback
};
};

0 comments on commit a84add1

Please sign in to comment.