Releases · mnorkin/yes-kafka

Trying release (b96619d)
Reject promise on failed initialization (98caee4)
Fix initialization of producer (a284237)
Switch 4 spaces to 2 spaces (ade7eb4)
Modernize eslint (7015a95)
Support for timeout publish (748b73f)
Version 1.0.0 (eb4c208)
Cleanup 2 (694c44b)
Cleanup (54766b8)
Update readme (304c750)
Increase delay (34cc5c9)
Finish with kafka ssl (e0e46a7)
Map ssl port (90ab683)
Update travis client cert key path (ba80d39)
Update travis configuration (7f0f68f)
Build docker image for ssl part (3ec2f9a)
Remove not nescesary comments (afb3a98)
Remove default values from functions and arrow functions (fb4b86b)
Fix for node 4 version (971efa2)
Node 4.4 compliant (b784a4b)
-- (41319b1)
Create mocha global timeout (d14c487)
Simple consumer increase timeout (4e58c6b)
Increase timeout (7b605f8)
Give kafka 10 seconds (346b3f6)
Give kafka 2s to start (45bce01)
Log travis info (17f51e0)
Fix lint (8da6ad8)
More tests, refactor tests to remove dependencies between them. Add dockerized kafka testkit (002e42d)
Fix eslint (4b52fb3)
Add test for retry message publish (cbd3e40)
Cleanup (f7ed2fb)
Fix multiple consumer/ producer per one instance of client (05322e9)
Rewrite to support old api (cacfdff)
Remove commented code (7532551)
Remove .only (814cf0d)
Rewrite client to support high volume of topics (082aa13)
3.3.5 (8a0802a)
Rate limit failed metadata request at 1 per minute (7f7307d)
3.3.4 (e396bf2)
Fix connection leak after metadata update (#232) (44a4740)
3.3.3 (890c8fd)
Update lodash (8529ac1)
3.3.2 (e8bfc47)
Update bin-protocol (63046c9)
3.3.1 (5861091)
Remove package-lock.json (a372906)
3.3.0 (ef202e2)
Update bin-protocol (e51fe87)
Drop Node 0.10, add Node 8.12 (5c07b5f)
3.2.10 (ec699b0)
Travis: opt into running apt-get update (eb54e04)
Update lodash to 4.17.5 (ad05eff)
Fix Kafka download url (0d81e8a)
3.2.9 (5a52527)
Fix offset recovery. Fixes #224 (1ef81fa)
3.2.8 (8a3eb2a)
Feature/validate ids (#213) (2178dea)
3.2.7 (91b95c4)
Removed typescript from deps (812d6ca)
3.2.6 (99b7fe6)
Fix types to export as modules rather than global declarations (#206) (0f97c3d)
3.2.5 (65fd7ff)
Add missing commitOffset in type definitions, fix fetchOffset return type and other small things (#200) (3ef50f2)
3.2.4 (5a1f76b)
Export all Typescript types (#198) (cabc512)
3.2.3 (e18b506)
Retry full rejoin on any error (0b4f107)
3.2.2 (204d972)
Trying to fix Travis (59e2056)
Trying to fix travis build failure (2186152)
Drop messages with wrong correlationId (af172ea)
3.2.1 (9d088d3)
Encrypt communication using self-signed certificate (#169) (7e954f1)
3.2.0 (1aa646c)
Add possibility to specify socket timeout (#188) (480e19d)
Fix code climate secure token config (75c7d46)
Add new secure codeclimate token (61f8bf4)
3.1.10 (f4247d3)
Update bin-protocol dep (757755a)
3.1.9 (40ae858)
Update typings (#181) (69289ca)
3.1.8 (5da6435)
Reject commitOffset call if group rebalance is in progress (82213b5)
3.1.7 (aa96595)
Test null/empty bytes type (#179) (052c81b)
3.1.6 (7a7dfaa)
Omit possible bluebird warning, fixes #173 (7256f7c)
Downgrade Snappy to 5.0.0 as 6.0.0 is causing illegal hardware instruction on OSX (893d7e6)
Revert "Update eslint and fix new lint errors" (7cf8cc4)
Update eslint and fix new lint errors (e64fc31)
Update sinon and sinon-chai (b8cfe8d)
Update Snappy (c886df3)
Restore codeclimate integration (f086835)
3.1.5 (53df4e5)
updateMetadata should return a Promise, fixes #172 (bfcd1ca)
3.1.4 (dad23cd)
comment (2d31201)
Typings for no-kafka (#165) (6549559)
Revert "Attemp to fix zero metadata in describeGroup response" (18c7365)
3.1.3-0 (fe97db0)
3.1.2 (e219c4e)
Attemp to fix zero metadata in describeGroup response (238fe7a)
3.1.1 (e91dc0f)
Add an ability to check consumer lag (#155) (eb17ec0)
README update (d9d44ec)
3.1.0 (098c91b)
New simplified ssl options (#150) (aa79438)
3.0.3 (05aa3a1)
Bugfixes preventing usage with Heroku Kafka (#142) (7c4137f)
3.0.2 (ab95aa9)
Add ability to specify SSL certificate/key as strings (#148) (e87ae62)
Update CHANGELOG.md (9e33d2e)
3.0.1 (abdaa14)
Remove ES6 syntax (f81926a)
Add HashCRC32Partitioner (2d8d000)
3.0 (#136) (5c91d2e)
2.9.2 (5a1357a)
Update lodash (#130) (8613b1c)
2.9.1 (d859b9b)
Update chai and mocha to fix security warnings on npm install (#128) (fd994b2)
2.9.0 (0da8332)
GroupConsumer: commit next to read offset instead of last consumed. Fixes #125 (9d3fb6f)
2.8.3 (718cf68)
Fix lodash version (98b3cb7)
2.8.2 (acab827)
Fix bug due to Promise.then race condition. Fixes #111 (5fb0cd2)
2.8.1 (b3c47be)
Rotate correlationId when it hits the bounds (cee7b12)
Simplify broker remapper (910cd07)
2.8.0 (2b7aacf)
Added brokerRedirection capability. (#114) (152787a)
2.7.1 (e5333cb)
Fix possible reordering of received messages. Closes #111 (7dabcf2)
2.7.0 (d01fc51)
Merge pull request #102 from p-thorpe/remove_make (54a5be0)
Tidy command paths (a814d8c)
Replace make with npm scripts (3e1ed69)
2.6.0 (8ff4b68)
Merge pull request #93 from steve-gray/master (1b0f384)
Exit from updateMetadata call loop when client.end() was called. Fixes #95 (b06c216)
2.5.6 (cac4102)
Skip single messages larger than maxBytes, fixes #74 (2317bf6)
Avoid null errors when snappy not installed. (79f2632)
Remove the explicit optional dep, because othewise it'll be installed. (abacfc8)
Remove redundant whitespace. (2b80e69)
More linting appeasement. (48b6e4a)
Formatting changes. (7845d63)
Packaging typo from cherry-picking. (c2b1cce)
Make snappy optional. (0533fa4)
2.5.5 (bfb2a87)
Merge pull request #85 from shvetsm/master (749e135)
._fetch has a broken Promise chain (6df9fc4)
Merge pull request #83 from frosas/patch-1 (c2c287c)
2.5.4 (ef33639)
Fix reconnection problem introduced with #80 (6a9ee81)
Document maxBytes default (42eefc7)
2.5.3 (61c0c72)
Merge pull request #77 from steve-gray/master (e1881a5)
Handle rapid shutdown of new instances (30a4481)
2.5.2 (fe98e03)
Use bin-protocol 3.0.2 (efc5fe6)
2.5.1 (ddb3045)
Reset spy in tests (2d1e342)
Test with Apache Kafka 0.10 (c055dfc)
Fix API version for OffsetFetch request (71d291c)
2.5.0 (1ff7556)
Add Client reconnectionDelay option for metadata request (7628519)
Retry metadata request on any error, including AggregateError from Promise.any which is returned when more than 1 broker connection failed (66fa163)
Node 4.3 -> 4.4 (067c48d)
Use less async iterations in Client#produceRequest (0101a79)
Cleanup Client#produceRequest (19049c4)
Cleanup Client#fetchRequest decompression (71f2407)
Make compression.{compress,decompress} return promises (789f80c)
Promisify decompression in Client (b4b4990)
Promisify call to compression in Client (c993df2)
2.4.2 (e158786)
Reload metadata when local copy doesn't have requested topic/partition. Fixes #49 (e9465ea)
2.4.1 (b53f8f2)
Make protocol in connectionString optional (03997a8)
Update README.md (160f1e8)
2.4.0 (07fd1a9)
Merge pull request #42 from hunterloftis/master (a253235)
parse KAFKA_URL from environment, if present (24293c8)
2.3.2 (c59b323)
Update deps (snappy) (d9af767)
2.3.1 (b92e480)
2.3.0 (8b47bd5)
Use bin-protocol 3.0.0 (faster) (8065d86)
2.2.2 (c613949)
Update README.md (8b09a7f)
Update README.md (5c095b5)
Break recursive promises loop because it triggers call stack overflow in some rare cases (f597761)
SKip unnecessary stack traces (ca70de0)
2.2.1 (fde3e27)
bluebird 3.3.3 (9496a96)
Update README.md (e6a5b20)
2.2.0 (1187a34)
rename consumer timeout option to maxWaitTime (6425105)
Use V1 for ProduceRequest but do not return throttleTime to user yet (will be backward incompatible) (10da622)
Update README.md (5f268db)
2.1.2 (b41ab5e)
Some code refactoring (609f2d3)
2.1.1 (a64daef)
Always unsubscribe on group rebalance. Fixes #30 (e760f64)
2.1.0 (c574506)
Add consumer handlerConcurrency option (36a4834)
Don't suggest to use concurrent Promise.map in consumer handler as commited offsets can easily be re-ordered (1a63120)
Use eslint-magictoolbox (4068aa2)
2.0.8 (3cea238)
Use own instance of Bluebird that enabled cancelation and doesn't conflict with other Bluebird instances (cb2b113)
README (562731a)
2.0.7 (7c7d25b)
README (35577bc)
Add keyed messages test and docs paragraph (f2d4542)
Use Promise cancellation in .end() to cancel fetch and feartbeat requests (dea7225)
2.0.6 (de88cea)
There is no sense in logging server for UnknownTopicOrPartition|NotLeaderForPartition|LeaderNotAvailable (db4f165)
2.0.5 (906e6ae)
Log server host:port on fetch error (bc36336)
Update eslint and airbnb-eslint (c5df2e3)
Test with Kafka 0.9.0.1 (6d0f3e3)
Some new tests (a6a9ecc)
Remove bithound integration. Pretty useless. (38582bb)
bithound config (caa3e7a)
Fix tests (0f318fa)
2.0.4 (5aac255)
Correctly verify partitioner option and promisify it before use. Fixes #27. (9b2412f)
proper .quote-props style (98246ce)
2.0.3 (b431ed1)
Fix warnings in tests (0a06182)
lodash 4.5.0 (0832aa5)
Update README.md (6f5c885)
messageSet field can be undefined in fetch response Fix for TypeError: Cannot read property 'forEach' of undefined (1c60706)
Update README.md (e12afcb)
2.0.2 (1849f7c)
Silence Warning: a promise was created in a handler Fixes #26 (01a81c1)
2.0.1 (5416512)
Fix decompression: Kafka can send more than a single compressed message in a MessageSet which is not according to the protocol guide: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Compression (402dc4b)
2.0.0 (c4eaf48)
Merge pull request #25 from oleksiyk/2.0 (e65cec9)
1.2.3 (98e9626)
README (9f6bff6)
Add some comments (726b650)
More tests (76b3537)
More tests (f916f...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Releases: mnorkin/yes-kafka

Release 1.0.11

Release 1.0.10

Release 1.0.9

Release 1.0.8

Release 1.0.5

Release 1.0.4

Release 1.0.3

Release 1.0.2