Hacktoberfest 2026: los issues que los mantenedores marcaron para octubre, abiertos y aptos para principiantes. Explorar issues de Hacktoberfest

[Error: Failed to create producer: TimeOut]

Abierto
#394 0 comentarios 4 reacciones 0 asignados Ver en GitHub

Nadie ha tomado este issue todavía.

Evaluación

Dificultad
4/5
Tiempo estimado
3-5 días
Aptitud para principiantes
25/100
Tipo de issue
Error
Claridad
Necesita aclaración
Estado de actividad
Estancado
Stack tecnológico
docker, docker-compose, javascript, node.js

Línea de trabajo

Reproduce el problema con los servicios de docker-compose proporcionados y el cliente Node.js usando pulsar://host.docker.internal:6650; empieza comprobando el registro de conexión del broker junto con la llamada a createProducer. Se considera completado cuando se haya identificado por qué el broker cierra la conexión y se haya registrado una corrección o un cambio de configuración verificado.

Escrito por el modelo de indexación a partir del texto del issue.

Descripción

I'm not able to create producer or consumer. I only get the error [Error: Failed to create producer: TimeOut]. I see opening and closing connection in broker log. I'm able to connect pulsar broker with Pulsar-Manager (the same netrwork, docker-compose).

used docker-compose:

services:
  pulsar:
    image: apachepulsar/pulsar:3.3.1
    command: sh -c "bin/apply-config-from-env.py conf/standalone.conf && bin/pulsar standalone"
    hostname: pulsar-local
    ports:
      - "8080:8080"
      - "6650:6650"
    restart: unless-stopped
    volumes:
      - "./conf:/pulsar/conf"
  dashboard:
    image: apachepulsar/pulsar-manager:v0.4.0
    ports:
      - "9527:9527"
      - "7750:7750"
    depends_on:
      - pulsar
    links:
      - pulsar
    environment:
      SPRING_CONFIGURATION_FILE: /pulsar-manager/pulsar-manager/application.properties

used nodejs client app:

const Pulsar = require("pulsar-client");

async function produceTest(timeout) {
  const client = new Pulsar.Client({
    serviceUrl: "pulsar://host.docker.internal:6650"
  });

  console.log('Create producer....');

  try {
    
    const producer = await client.createProducer({
      topic: "persistent://public/default/test1",
      sendTimeoutMs: 30000
    });

    console.log('before');

    await new Promise((resolve, reject) => {
      setTimeout(() => {
        producer.send({
          data: Buffer.from("My Message")
        });
        resolve();
      }, timeout);
    });

  } catch(e) {

    console.error(e);
  }
  

  console.log('after');

  await client.close();
}

produceTest(1000);

Pulsar broker log:

2024-09-17 12:47:18 2024-09-17T10:47:18,331+0000 [pulsar-io-18-15] INFO  org.apache.pulsar.broker.service.ServerCnx - [/172.22.0.1:37994] connected with clientVersion=Pulsar-CPP-v3.5.1, clientProtocolVersion=20, proxyVersion=null
2024-09-17 12:47:18 2024-09-17T10:47:18,333+0000 [pulsar-io-18-15] INFO  org.apache.pulsar.broker.service.ServerCnx - Closed connection from /172.22.0.1:37994
Lenguaje dominante
C++
Estrellas
164
Forks
99
Merge medio
5 d 18 h
PR fusionados (30 d)
2

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Primeros pasos

  1. Lee el issue completo y luego la guía de contribución del proyecto.
  2. Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
  3. Haz un fork del repositorio y trabaja en una rama.
  4. Abre un pull request que haga referencia al número del issue.

Más de apache/pulsar-client-node

Todos los issues de apache/pulsar-client-node

Issues similares

Más issues de C++

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.