oleksiyk/kafka

Issues

• Module is not throwing an error if it GroupAuthorizationFailed instead its simply printing error message.

  #269 opened 3 months ago by vinaykumar612
  1

• WARN no-kafka-client No partition assignment received

  #268 opened a year ago by vinaykumar612
  0

• There is no way to set enable.auto.commit config for a consumer

  #267 opened 3 years ago by jainshivsagar
  0

• support inquiry

  #266 opened 3 years ago by ghinks
  2

• Use of Promise.each() inside GroupConsumer dataHandler

  #258 opened 5 years ago by johncmunson
  3

• Kafka SASL credential based authentication support for producer and consumer

  #255 opened 5 years ago by abhishekgupta-lab
  0

• Lodash dependency is a security vulnerability

  #253 opened 5 years ago by Chengxuan
  1

• Group Consumer :How do we get messages in groupConsumer specifying startOffset and Lastoffset

  #220 opened 7 years ago by tmruthyu
  1

• How to ensure all messages are read

  #251 opened 6 years ago by rafaelvicio
  0

• Return a message to the topic

  #250 opened 6 years ago by rafaelvicio
  0

• NoKafkaConnectionError message : "Connection timeout"

  #201 opened 7 years ago by arpanimage
  6

• consume non existing topic

  #247 opened 6 years ago by larryckey
  0

• "--from-beginning" consumer equivalent?

  #246 opened 6 years ago by vbhayden
  0

• If consumer group Id is wrong not throwing any error

  #242 opened 6 years ago by ashwinismath
  2

• Support Delete Topics

  #235 opened 6 years ago by callmekatootie
  0

• Init producer just one time

  #205 opened 7 years ago by arturogalan
  4

• 'Connection was aborted before connection was established.' gets stuck in a loop.

  #233 opened 6 years ago by svakili
  0

• Lodash dependency is a security vulnerability

  #227 opened 6 years ago by rakeshramakrishnan
  2

• Consumer not working with SSL certificate

  #231 opened 6 years ago by ashwinismath
  0

• For enable_auto_commit False, no automatic re-join ; Error Heartbeat: local member_id was not recognized; this consumer needs to re-join

  #229 opened 6 years ago by silwalprabin
  2

• Message timestamps as in KIP-32

  #228 opened 7 years ago by alexeevg
  0

• Unable to compile no-kafka v 3.2.10 in Angular 6

  #226 opened 7 years ago by Son-Lam
  0

• LeaderNotAvailable disguised as UnknownTopicOrPartition

  #225 opened 7 years ago by zvictor
  1

• Bad signature for getPartitionOffset in base_consumer.js line 95

  #224 opened 7 years ago by ElHassaniWalid
  1

• Unclear error handling for over-sized message.

  #223 opened 7 years ago by Chengxuan
  1

• GroupCoordinatorNotAvailable Error Ignored or swallowed?

  #222 opened 7 years ago by srinivasankrish
  0

• GroupConsumer : lack of some internal functionality

  #216 opened 7 years ago by itrambovetskyi
  5

• Support for adding headers in Kafka Message

  #221 opened 7 years ago by sundarkvp
  1

• supporting kafka 0.11.0.x

  #204 opened 7 years ago by hugebdu
  4

• Error handling of consumer data handler

  #219 opened 7 years ago by steffansluis
  1

• One slow broker can slow fetch responses from all brokers

  #218 opened 7 years ago by thomaslee
  0

• How to check if topic exists?

  #191 opened 7 years ago by jdconley
  2

• Simple Consumer Failed to Connect to Broker

  #215 opened 7 years ago by iicervantes
  2

• Cannot read property offset

  #207 opened 7 years ago by kroyhpe
  4

• Payload length mismatch on the producer side

  #214 opened 7 years ago by kroyhpe
  1

• Large unused dependencies

  #209 opened 7 years ago by kjvalencik
  6

• Kafka server has closed connection

  #212 opened 7 years ago by VineetKillerX
  1

• NokafkaConnectionError - Connection Timeout

  #210 opened 7 years ago by arpanimage
  1

• handling promises in no-kafka

  #202 opened 7 years ago by sharathbaddam
  4

• Restricting Message size from no-kafka Producer

  #208 opened 7 years ago by VineetKillerX
  10

• Connection timeout not resulting in retries

  #203 opened 7 years ago by arpanimage
  0

• no -kafka with node js behaving inconsistently

  #199 opened 7 years ago by VineetKillerX
  6

• commitOffset missing from SimpleConsumer type

  #190 opened 7 years ago by steffansluis
  4

• Use Stream api

  #197 opened 7 years ago by mjafarpour
  1

• how to handle consuming for adding partition

  #195 opened 7 years ago by wangsong412
  2

• Support LZ4 compression

  #194 opened 7 years ago by shaharmor
  0

• A pem cert with a trust chain can't be read from a variable

  #192 opened 7 years ago by coolov
  0

• wrong tag

  #186 opened 8 years ago by maturanafp
  1

• SASL PLAIN Authentication Support?

  #189 opened 7 years ago by ecbatana
  2

• no-kafka API with Root CA?

  #187 opened 8 years ago by maturanafp
  0