Adjusting compose and test to be fair

Author: CarlosGamero

docker-compose.yml

@@ -42,6 +42,33 @@ services:
     container_name: kafka
     ports:
       - 9092:9092
+    environment:
+      KAFKA_NODE_ID: 1
+      KAFKA_PROCESS_ROLES: broker,controller
+      KAFKA_LISTENERS: LOCAL://0.0.0.0:9092,DOCKER://kafka:9093,CONTROLLER://localhost:9094
+      KAFKA_ADVERTISED_LISTENERS: LOCAL://localhost:9092,DOCKER://kafka:9093
+      KAFKA_INTER_BROKER_LISTENER_NAME: LOCAL
+      KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: CONTROLLER:PLAINTEXT,LOCAL:PLAINTEXT,DOCKER:PLAINTEXT
+      KAFKA_CONTROLLER_QUORUM_VOTERS: 1@localhost:9094
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
+      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
+      KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
+      KAFKA_NUM_PARTITIONS: 1
+    restart: on-failure
+
+  kafka-ui:
+    container_name: kafka-ui
+    image: provectuslabs/kafka-ui:latest
+    ports:
+      - 8080:8080
+    depends_on:
+      - kafka
+    environment:
+      DYNAMIC_CONFIG_ENABLED: 'true'
+      KAFKA_CLUSTERS_0_NAME: Local
+      KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: kafka:9093
     restart: on-failure
 
 volumes:

packages/kafka/lib/test.spec.ts

@@ -1,15 +1,11 @@
+import { randomUUID } from 'node:crypto'
 import { once } from 'node:events'
 import { waitAndRetry } from '@lokalise/universal-ts-utils/node'
-import { KafkaConsumer, type Message, Producer, features, librdkafkaVersion } from 'node-rdkafka'
+import { KafkaConsumer, type Message, Producer } from 'node-rdkafka'
 
 // TODO: to be removed once we have proper tests
 describe('Test', () => {
-  it('should use node-rdkafka', () => {
-    expect(features).toBeDefined()
-    expect(librdkafkaVersion).toBeDefined()
-  })
-
-  it('should send and receive a message', { timeout: 10000 }, async () => {
+  it('should send and receive a message', async () => {
     // Given
     const brokers = 'localhost:9092'
     // Use a fresh, unique topic per run to avoid stale state
@@ -26,13 +22,11 @@ describe('Test', () => {
     producer.connect()
     await once(producer, 'ready')
 
-    // Create a consumer with a unique group and disable auto-commit for fresh offsets
     const consumer = new KafkaConsumer(
       {
-        'group.id': 'test-group',
+        'group.id': randomUUID(),
         'metadata.broker.list': brokers,
         'allow.auto.create.topics': true,
-        'enable.auto.commit': false,
       },
       { 'auto.offset.reset': 'earliest' },
     )
@@ -56,7 +50,7 @@ describe('Test', () => {
     producer.flush()
 
     // Then
-    await waitAndRetry(() => receivedMessages.length > 0, 10, 800)
+    await waitAndRetry(() => receivedMessages.length > 0, 10, 1000)
     expect(receivedMessages).toHaveLength(1)
     expect(receivedMessages[0]?.value?.toString()).toBe(messageValue)