archive-gh-me/node-kafka-rest-client
1
0
Fork 0
mirror of https://github.com/uber-common/node-kafka-rest-client.git synced 2026-02-01 17:27:30 +00:00
Code Issues Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
Hongliang Xu 2017-01-30 23:21:31 -08:00
parent 7acb946352
commit 87dcff93b3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/kafka_base_producer.js
View File

@ -269,7 +269,7 @@ KafkaBaseProducer.prototype.produceSync = function produce(topic, producerRecord
producerRecord.value, Date.now() / 1000, 'binary');
self._produce(produceMessage, callback);
if (self.isHeatPipeTopic(topic) && self.enableAuditC3 && topic !== self.auditTopicNameC3) {
if (self.restClient.isHeatPipeTopic(topic) && self.enableAuditC3 && topic !== self.auditTopicNameC3) {
var timeBeginInSecC3 = self._getTimeBeginInSecFromHp(producerRecord.value);
self._auditNewMsg(topic, timeBeginInSecC3, 1, self.topicToMsgcntMapsAtProduce);
}