Skip to content

Pull requests: SOHU-Co/kafka-node

New pull request New
47 Open 488 Closed
47 Open 488 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Allow reuse of kafkaClient fo consumerGroup and producerStream
#1476 opened Aug 26, 2023 by hosh Loading…
Improvement of topic validation
#1471 opened May 10, 2023 by bisand Loading…
fix ECONNRESET for TLS connections
#1470 opened May 9, 2023 by CatalinManolescu Loading…
Make options param for Consumer optional.
#1469 opened Mar 13, 2023 by mjhult Loading…
docs: update README to add possible values for requireAcks producer config
#1455 opened Oct 4, 2021 by deepal Loading…
fix #1449 : check controllerMetadata is not null
#1450 opened Jun 28, 2021 by jasonseparovic Loading…
protocol.js-OOM-fix
#1446 opened Apr 28, 2021 by debarghyaroy012 Loading…
Fix add types for Admin and fix some type error
#1440 opened Dec 27, 2020 by Tseian Loading…
1
Handle 'offsetOutOfRange' error in consumer (similar to the handling in consumerGroup)
#1438 opened Dec 6, 2020 by assaf-xm Loading…
Vulnerability - Upgrade bl to v2.2.1
#1432 opened Oct 15, 2020 by sergiopereirain Loading…
add types for kafka Admin
#1424 opened Aug 11, 2020 by tobydigz Loading…
Feature: added sasl scram 256 and 512 functionality
#1392 opened Mar 20, 2020 by 0807Jpatel Loading…
6
Fixed isAsync params usage for createTopics (#900)
#1370 opened Jan 3, 2020 by lamweili Loading…
1
1
Added PartitionerTypes interface for Producer
#1365 opened Dec 16, 2019 by dorin131 Loading…
Fix first producer send missing metadata
#1360 opened Dec 3, 2019 by alex3165 Loading…
1
Make socket keepAlive time configurable
#1338 opened Oct 10, 2019 by dotanrs Loading…
add all condition why message ignored
#1330 opened Sep 19, 2019 by whomobile Loading…
Tests for Kafka version 2.12-2.1.1 and 2.12-2.2.1
#1327 opened Sep 16, 2019 by hxinhan Loading…
1
Added interface for Admin to index
#1323 opened Sep 12, 2019 by dSolver Loading…
superss and log an unhandeled error to prevent process from crashing
#1295 opened Jul 3, 2019 by tomer-amir-vonage Loading…
1
Fixed bug when autoCommit arguments length equal 0
#1292 opened Jun 21, 2019 by huip Loading…
Fix ConsumerGroupStream commit payload type
#1284 opened Jun 14, 2019 by iffyio Loading…
Fix check topic partition change by load topic metadata from keys of consumerGroup.topicPartitionLength
#1281 opened Jun 10, 2019 by thynson Loading…
6
add reconnect to kafka code after kafka broker down
#1274 opened May 28, 2019 by tomgiggs Loading…
1
fix infinite loop
#1272 opened May 24, 2019 by makhtev Loading…
1
ProTip! Mix and match filters to narrow down what you’re looking for.