Aaron Peloquin

Confluent vs KafkaJS performance feedback

11

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)....

How to use logging callback?

2

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...

Unable to construct viable Docker image using `node:20-alpine`

4

Our build uses an `ubuntu-latest` Github runner to build a Docker image.  Our Dockerfile follows the [example](https://github.com/confluentinc/confluent-kafka-javascript/blob/9e803e0f72f568b6ccb101e2803299fe46579620/examples/node-rdkafka/docker-alpine.md?plain=1) provided in this repo. ```dockerfile FROM node:20-alpine COPY ./dist /app/ WORKDIR /app...

Help with SSL mapping

1

Since SSL mapping is not provided as part of the KafkaJS config migration, I have a question on how to migrate a KafkaJS SSL configuration. We have 3rd party SSL-based...

Confluent connections interfere with KafkaJS connections when SSL is involved

1

This is an odd one. We're attempting to phase-in use of the Confluent library to our app for new functionality. This app has existing functionality using KafkaJS, and the existing...

batch size limit is severely limiting compared to KafkaJS

1

**Environment Information** - OS: Mac M3 Sonoma 14.6.1 - Node Version: 22.12.0 - NPM Version: 10.9.0 - confluent-kafka-javascript version: 1.2.0 **Context** The [migration guide](https://github.com/confluentinc/confluent-kafka-javascript/blob/master/MIGRATION.md#semantic-and-per-method-changes-1) states: > An API compatible version...

**Environment Information** - OS: Mac M3 Sonoma 14.6.1 - Node Version: 22.12.0 - NPM Version: 10.9.0 - confluent-kafka-javascript version: 1.2.0 **Steps to Reproduce** Setting up a consumer to process a...

**Environment Information** - OS: Mac M3 Sonoma 14.6.1: - Node Version: 22.12.0 - NPM Version: 10.9.0: - confluent-kafka-javascript version: 1.2.0 **Steps to Reproduce** Attempt to use `highWatermark` on _EachBatchPayload_. Value...

Request: more context in errors reported to logger, specifically 'Unknown topic or partition'

2

**Environment Information** - OS: Mac M3 Sonoma 14.6.1 - Node Version: 20.14.0 - NPM Version: 10.7.0 - confluent-kafka-javascript version: 1.0.0 **Steps to Reproduce** In general the errors sent to the...