kafka

kafka copied to clipboard

Clear out timeout timer when connection is made

1

I init() a connection, send() messages and then end() the connection in less than 500ms. The timer was on the event loop so node would exit after 3+ seconds. My...

rmdave

Here's some thinking: - Add a new class 'KafkaProxy' (note, to avoid conflict with future ES6 proxy, prefixed name). - Proxy would act as a single, stateful bridge to a...

steve-gray

GroupCoordinatorNotAvailable Issue

1

I'm trying use docker-compose to bring up both my group consumer and a docker container running kafka. There is an issue with timing where some times the consumer init code...

Mattenable

Do not allow consumer with empty list of subscriptions.

3

Hi, first thanks a lot for this great client! We had a bug today, were we did pass an empty list (by mistake) of subscription to the strategy of `GroupConsumer`,...

aloiscochard

GroupConsumer inits successfully with invalid host and will not end

1

See https://github.com/Mattenable/no-kafka-test Can you help me figure out what I'm doing wrong? I'd like the connection attempts to stop. First issue is I would expect consumer init to fail, but...

Mattenable

Synchronous protocol deserialization blocking event loop

7

I am running a system that processes about 3M messages per day. It uses Node 0.10, Kafka 0.9 and high level consumers using no-kafka 2.5.6. When fetch sizes get large,...

darthjoel

Can a missing topic/partition error message indicate the actual topic/partition value?

2

The library will emit this error ``` { [KafkaError: This request is for a topic or partition that does not exist on this broker.] name: 'KafkaError', code: 'UnknownTopicOrPartition', message: 'This...

memelet

Suggested in https://github.com/oleksiyk/kafka/issues/59

oleksiyk

pattern-matched topic subscriptions

1

Do you plan to support subscription to multiple topics via pattern matching (as in the official Java API: http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener) )?

jevad

Could you please explain what does it mean `WARN no-kafka-client No partition assignment received`

vinaykumar612