This message was deleted.

This message was deleted.

This message was deleted.

set the channel topic: ⁉️ If you have a question, please ask it at https://github.com/apache/pulsar/discussions or https://stackoverflow.com/questions/tagged/apache-pulsar. It will make it searchable by others.

set the channel description: General discussion about Apache Pulsar.

This message was deleted.

Which Pulsar version do you use in production? Please vote here: https://github.com/apache/pulsar/discussions/19531

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

@Hugo Smitter If you are looking for a way to interact with Pulsar without using client libraries over the HTTP protocol, you can also look at Pulsar’s consumer REST endpoint as well.

This message was deleted.

@David K The use case is webhooks. We want send an outbound POST to an external customer webhook from a Pulsar topic.

Thanks Hugo. In that case either solution should work. Again, it really comes down to the payload you intend to send (schema, key, properties), message delivery guarantees (idempotent producer), and geo-replication concerns.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

This message was deleted.

[BookeepercientWorker-0rderedExecutor-11-0] ERROR org.pachebookkeeper.mledger.impl.ManagedCursorImpl - pulsar/gprs/persistent/16_rate_in-partition-19][controlNode-16] Metadata ledger creation failedjclbil133'pulsar-broker-jclbill33

Hi everyone! I don’t think anyone will argue, it’s important to have a fresh-looking website to attract new users. I decided to try to refresh it a little bit. Over the weekend I managed to make a home page. I think that I can finish other pages in 1-2 weeks, depending on my workload. Current version: https://pulsar.apache.org/ New version: https://pulsar-site-three.vercel.app/ Draft PR: https://github.com/apache/pulsar-site/pull/426 After the redesign, I plan to add a few more pages. Should I continue? Before After

{"logLevel":"ERROR","logThread":"ReplicationWorker","logger":"org.apache.bookkeeper.replication.ReplicationWorker","message":"UnavailableException while replicating fragments","stack_trace":"org.apache.bookkeeper.replication.ReplicationException$UnavailableException: Error contacting zookeeper \tat org.apache.bookkeeper.meta.ZkLedgerUnderreplicationManager.isLedgerReplicationEnabled(ZkLedgerUnderreplicationManager.java:728) \tat org.apache.bookkeeper.meta.ZkLedgerUnderreplicationManager.waitIfLedgerReplicationDisabled(ZkLedgerUnderreplicationManager.java:619) \tat org.apache.bookkeeper.meta.ZkLedgerUnderreplicationManager.getLedgerToRereplicate(ZkLedgerUnderreplicationManager.java:600) \tat org.apache.bookkeeper.replication.ReplicationWorker.rereplicate(ReplicationWorker.java:272) \tat org.apache.bookkeeper.replication.ReplicationWorker.run(ReplicationWorker.java:238) \tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) \tat java.lang.Thread.run(Thread.java:748) Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /ledgers/underreplication/disable \tat org.apache.zookeeper.KeeperException.create(KeeperException.java:102) \tat org.apache.zookeeper.KeeperException.create(KeeperException.java:54) \tat org.apache.zookeeper.ZooKeeper.exists(ZooKeeper.java:2021) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient.access$2301(ZooKeeperClient.java:70) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient$13.call(ZooKeeperClient.java:830) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient$13.call(ZooKeeperClient.java:824) \tat org.apache.bookkeeper.zookeeper.ZooWorker.syncCallWithRetries(ZooWorker.java:140) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient.exists(ZooKeeperClient.java:824) \tat org.apache.zookeeper.ZooKeeper.exists(ZooKeeper.java:2049) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient.access$2401(ZooKeeperClient.java:70) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient$14.call(ZooKeeperClient.java:851) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient$14.call(ZooKeeperClient.java:845) \tat org.apache.bookkeeper.zookeeper.ZooWorker.syncCallWithRetries(ZooWorker.java:140) \tat org.apache.bookkeeper.zookeeper.ZooKeeperClient.exists(ZooKeeperClient.java:845) \tat org.apache.bookkeeper.meta.ZkLedgerUnderreplicationManager.isLedgerReplicationEnabled(ZkLedgerUnderreplicationManager.java:723) \t... 6 more "}

Does the error reported by bookie have any impact on producers and consumers?

054335.364 [main-EventThread] ERROR o.a.b.meta.ZkLedgerIdGenerator - Could not generate new ledger id org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /ledgers/idgen-long/HOB-0000000001/ID- at org.apache.zookeeper.KeeperException.create(KeeperException.java:99) ~[zookeeper-3.4.6.jar:3.4.6-1569965] at org.apache.zookeeper.KeeperException.create(KeeperException.java:51) ~[zookeeper-3.4.6.jar:3.4.6-1569965] at org.apache.bookkeeper.meta.ZkLedgerIdGenerator$1.processResult(ZkLedgerIdGenerator.java:78) ~[bookkeeper-server-4.3.1.56-yahoo.jar:4.3.1.56-yahoo] at org.apache.bookkeeper.util.ZkUtils$1.processResult(ZkUtils.java:79) [bookkeeper-server-4.3.1.56-yahoo.jar:4.3.1.56-yahoo] at org.apache.bookkeeper.zookeeper.ZooKeeperClient$9$1.processResult(ZooKeeperClient.java:527) [bookkeeper-server-4.3.1.56-yahoo.jar:4.3.1.56-yahoo] at org.apache.zookeeper.ClientCnxn$EventThread.processEvent(ClientCnxn.java:605) [zookeeper-3.4.6.jar:3.4.6-1569965] at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:498) [zookeeper-3.4.6.jar:3.4.6-1569965]

And this question

Does the error reported by bookie have any impact on producers and consumers?

set the channel topic: ⁉️ If you have a question, please consider asking it at https://github.com/apache/pulsar/discussions/new?category=q-a or https://stackoverflow.com/questions/ask?tags=apache-pulsar. It will make it searchable by others.

This message was deleted.

This message was deleted.