tulios/kafkajs

Issues

• Support for Cloudflare sockets connect

  #1713 opened a month ago by devinrsmith
  0

• Crash: KafkaJSNonRetriableError: Specified group generation id is not valid

  #1712 opened a month ago by oleh-poberezhets
  0

• 消费者端无法连接到kafka，连接地址被固定

  #1689 opened 4 months ago by Dr-SummerFlower
  10

• KafkaJSConnectionClosedError: Closed connection

  #1711 opened a month ago by kante-srikanth
  0

• Contribution Proposal: SASL_PLAINTEXT GSSAPI Authentication Support

  #1710 opened a month ago by jonathannaim
  0

• Issue with Message Processing or consumption in few Partitions

  #1708 opened 2 months ago by SantoshAvaji
  0

• What is max size of Message[]?

  #1707 opened 2 months ago by Alocart
  3

• Increate KafkaJS producer default retry

  #1673 opened 6 months ago by TiansuYu
  1

• TooManyRequestsError doc questions (doubts)

  #1701 opened 3 months ago by guilherme90
  2

• Enhance the instrumentations events to support metrics collection

  #1706 opened 2 months ago by ilia-beliaev-miro
  0

• Filter Messages by Header Before Deserialization

  #1705 opened 2 months ago by amine-abdelli
  0

• Check pending requests runs in an infinite loop

  #1704 opened 3 months ago by robbynshaw
  0

• Consumer receives eachBatch over the maxBytes

  #1694 opened 4 months ago by akospaska
  1

• Kafka upgrade 2.7 -> 3.6

  #1681 opened 3 months ago by brennonh
  4

• Introduce Kafkajs startup project prompt Invalid or unexpected token

  #1702 opened 3 months ago by chargeduck
  0

• While using eachBatch(), the consumer isn't processing messages from each batch and just calling multiple batches

  #1700 opened 3 months ago by anupamd2-zluri
  0

• KafkaJSRequestTimeoutError during consumption leading to partition backlog

  #1691 opened 3 months ago by xiaoxiaodek
  0

• Section anchor tags on right sidebar not working

  #1699 opened 3 months ago by Praddyumn16
  1

• Re Consuming KafkaJs

  #1697 opened 3 months ago by MAhmadIqbal
  0

• Treat throttling errors as retriable

  #1696 opened 4 months ago by richardartoul
  0

• There is any way to find the connection pool size of my application?

  #1669 opened 7 months ago by juniorsdj
  3

• maxBytesPerPartition not working as stated in the documentation

  #1677 opened 5 months ago by abhinavgautam07
  1

• Kafka Api Versions missing

  #1693 opened 4 months ago by PrestonGiorgianni
  0

• more than one runner with one consumer.

  #1692 opened 4 months ago by WinZawOoDev
  0

• Consumer can process only messages from one topic at a time

  #1688 opened 4 months ago by ari-github
  3

• Provide function on producer that returns partition for message key of topic

  #1690 opened 4 months ago by timsauvageot
  0

• When the KafkaJS Consumer pulls messages from Kafka

  #1682 opened 5 months ago by shyswy
  1

• Problems when concurrently consume from the same topic to the same consumer group id.

  #1687 opened 4 months ago by Sang-Mook
  0

• Producer failover and promise reject when a broker is disconnected

  #1686 opened 4 months ago by byrne-greg
  0

• [Question] How do I subscribe to future topics using a pattern?

  #1685 opened 4 months ago by dulguun0225
  0

• Is it possible to consume a topic with multiple schemas ?

  #1680 opened 5 months ago by houdheyfa
  1

• kafkajs is not compatible with Nodev18

  #1662 opened 8 months ago by saifahmedkhan9
  5

• Has this project been abandoned?

  #1678 opened 5 months ago by weslleyshavo
  1

• Question: Is there a way to get the status of all consumers inside a consumer group?

  #1674 opened 6 months ago by cris2123
  1

• KafkaJS Consumer Offset Reset Issue after Manual Commit

  #1660 opened 8 months ago by aderounmu
  3

• RoundRobin Assignor doesn't acknowledge Member subscribed topics in assignment

  #1679 opened 5 months ago by edeesis
  0

• [readme] Community Slack invitation link is broken

  #1676 opened 5 months ago by pwn-0x309
  1

• Kafka producer.send(timeout: 1) other than 1ms- no other number seems to be working

  #1675 opened 5 months ago by spatel6904
  0

• How to consume messages from multiple topics

  #1672 opened 6 months ago by Torchu
  1

• Bumping "ip" dev dependency to latest (prevent false-positives from vulnerability scanners)

  #1671 opened 6 months ago by ethanae
  1

• `eachBatchAutoResolve: false` and using of transaction`tx` results in an infinite number of messages

  #1665 opened 6 months ago by danilredko
  0

• Missing customLogger when sending message

  #1668 opened 7 months ago by andreseloysv
  0

• How to prioritise the topic in KafkaJS

  #1666 opened 7 months ago by telia-ankita
  0

• Can I assign a consumer to a specific partition ?

  #1664 opened 8 months ago by ShubhanshuSharma-hub
  0

• Forking the repo to my company for now ExtendOSS/kafkajs come contribute

  #1661 opened 8 months ago by HeatherFlux
  0

• Question: How to add multiple subscribers

  #1659 opened 8 months ago by right-fish
  0

• KafkaJSGroupCoordinatorNotFound: Failed to find group coordinator

  #1654 opened 9 months ago by arupsarkar-sfdc
  2

• "[BrokerPool] Failed to connect to seed broker, trying another broker from the list: Connection error: Client network socket disconnected before secure TLS connection was established"

  #1658 opened 8 months ago by EmmanDizon
  0

• Incorrect API Versions Used on Clusters with Mixed Kafka Versions

  #1656 opened 9 months ago by gtowne
  0

• Help with idempotent

  #1653 opened 9 months ago by gutoberny
  0