Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Error: Failed to create producer: TimeOut] #394

Open
ltecze opened this issue Sep 17, 2024 · 0 comments
Open

[Error: Failed to create producer: TimeOut] #394

ltecze opened this issue Sep 17, 2024 · 0 comments

Comments

@ltecze
Copy link

ltecze commented Sep 17, 2024

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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant