confluent-kafka-javascript
confluent-kafka-javascript copied to clipboard
confluentinc
Confluent's Apache Kafka JavaScript client
This is a routine update from cc-service-bot based on the service.yml in your repo. This PR should be approved and merged as soon as CI passes.
I ran a test sending and receiving 1000 messages individually (no batching) using the KafkaJS library, and then ran the same test using the Confluent library (following the migration instructions)....
With KafkaJS, we used the `logCreator` config field on when creating the Kafka instance. That has been removed in this library. I see the underlying rdkafka supports a `log_cb` logging...
```ts const kafka = new Kafka({ kafkaJS: { brokers: ["localhost:9092"] } }); const consumer = kafka.consumer({ kafkaJS: {groupId: GROUP_ID} }); await consumer.connect(); ``` Results in the following log entries, even...
* store() - done * setting sasl credentials dynamically - done * subscriptions() * epoch related fields on partitions - as in v2.1.0 of librdkafka - done * metadata commit...
For example: listing topics, ACL operations, consumer group operations, consumer group offset operations.
Contains changes and error handling for the consumer. --- We might need to take a deeper dive into seeing how auto-commit is handled, as well as multiple eachMessage's dispatched at...