20 Commits

Author	SHA1	Message	Date
Xiaoman Dong	a9afaaf289	fix jshint errors	2018-04-12 11:25:14 -07:00
Xiaoman Dong	3196119a92	Address all lint issue	2018-04-06 16:55:17 -07:00
Xiaobing Li	d4691158b5	enable C3	2016-11-23 09:43:49 -08:00
Stephen Huenneke	12d7b8a289	Refactor test to explicitly check for correct message writing.	2016-04-19 14:16:58 -07:00
Stephen Huenneke	e4c88a9a74	Adding tests for large message body.	2016-04-19 14:16:47 -07:00
Stephen Huenneke	0a1a8d4f74	Drop messages that aren't strings or Buffer's when received in KafkaProducer.batch()	2016-04-19 14:16:47 -07:00
Stephen Huenneke	7ed9b1fbc7	Move error handling for bad message types (e.g. not buffer and not string) to KafkaProducer.batch()	2016-04-19 14:16:47 -07:00
Stephen Huenneke	639201c0b7	Adding callbacks to avoid throwing errors; Better const-like behavior with Object.freeze on padding constants.	2016-04-19 14:16:47 -07:00
Stephen Huenneke	2bc4d7b481	Add helper methods to properly calculate full size of a single message when it's being sent as a batch. Fixes a bug where messages of length greater than (producer.maxBatchSizeBytes - 8) and producer.maxBatchSizeBytes would end up getting truncated because of offsets in the message Buffer.	2016-04-19 14:16:47 -07:00
Hongliang Xu	7fa81c5db6	rebase to origin/master and change test_kafka_rest_client to parallel	2016-04-10 20:51:34 -07:00
Brandon Layton	0e561df0f3	Fix tests	2016-04-06 16:48:22 -07:00
Raynos	a29e2c1832	ensure that batching mode blocks cb on write flushed	2015-12-28 23:08:25 -08:00
Raynos	3db94add4c	message_batch: ensure callback gets called in addMessage()	2015-12-28 22:17:56 -08:00
Brandon White	4b5a27c400	more tests for messagesize	2015-12-23 00:00:18 -08:00
Brandon White	fc25ca5bae	copy cachedBuf to new buffer when getting batched message and reset buffer offsets instead of creating a new one	2015-12-22 23:33:22 -08:00
Brandon White	6ca3036f77	micro-ops	2015-12-22 22:33:50 -08:00
Brandon White	673759bf9c	update MessageBatch tests	2015-12-22 22:14:54 -08:00
Brandon White	778dce1773	linting	2015-12-22 19:23:07 -08:00
Brandon White	585ae01ae9	Update message_batch.js	2015-12-22 19:22:08 -08:00
Brandon White	7755740fed	refactor batchmessage to be more efficient by replacing concats	2015-12-22 19:20:53 -08:00