David K
07/03/2024, 6:52 PMsbourke
07/03/2024, 7:34 PMJason S
07/08/2024, 11:08 AMquarkus.pulsar.devservices.broker-config.functionsWorkerEnabled=true
quarkus.pulsar.devservices.image-name=apachepulsar/pulsar:3.3.0
I have confirmed that this is behaving as expected as when I load the broker runtime configurations, I can see that the setting is true.
{
...removed for brevity
functionsWorkerEnabled=true
...removed for brevity
}
I create the admin client as follows:
var client = PulsarAdmin.builder().serviceHttpUrl(adminBrokerUrl).build();
I tried calling the REST API directly and get the same error: Request:
/admin/v3/functions/public/default/listFunctions
Response:
{
"reason": "Pulsar Function Worker is not enabled, probably functionsWorkerEnabled is set to false"
}
I checked the documentation to see if I need to set any other configs but as I understand from the documentation all other settings are inherited from the broker config.
The expectation would be that I would receive an empty List from the client or a list of functions names set up on the broker when calling:
client.functions().getFunctions(tenant, namespace);
However, I get the error:
I get the error:
Error getting functions: org.apache.pulsar.client.admin.PulsarAdminException$ConflictException: Pulsar Function Worker is not enabled, probably functionsWorkerEnabled is set to false
David K
07/08/2024, 6:24 PMfunctionsWorkerEnabled=false
?Arjun Kishore
07/09/2024, 6:39 AMAmy Krishnamohan
07/09/2024, 9:32 PMSrinivas Tadimalla
07/10/2024, 1:44 AMSrinivas Tadimalla
07/10/2024, 1:45 AMSrinivas Tadimalla
07/10/2024, 1:49 AMSrinivas Tadimalla
07/10/2024, 1:50 AMSrinivas Tadimalla
07/10/2024, 2:07 AMSrinivas Tadimalla
07/10/2024, 2:14 AMSrinivas Tadimalla
07/10/2024, 8:03 AMantliu
07/10/2024, 8:11 AMRonald Ramazanov
07/10/2024, 3:16 PM[main] ERROR org.apache.bookkeeper.bookie.LegacyCookieValidation - There are directories without a cookie, and this is neither a new environment, nor is storage expansion enabled. Empty directories are [/pulsar/data/bookkeeper/journal/current, /pulsar/data/bookkeeper/ledgers/current]
2024-07-10T12:56:41,133+0000 [main] ERROR org.apache.bookkeeper.server.Main - Failed to build bookie server
org.apache.bookkeeper.bookie.BookieException$InvalidCookieException:
I tried to find the necessary steps in the documentation but couldn’t find anything suitable. What is the correct sequence of actions for such failures?
I would appreciate any feedback. Thank you!
PS - Apache Pulsar is running in a Kubernetes cluster using the Helm chartpavankumar reddy
07/11/2024, 1:04 PMAlexandre Brilhante
07/13/2024, 3:35 PMCĂ´ng Nguyá»…n ThĂ nh
07/15/2024, 8:44 AMrahul
07/16/2024, 2:59 PMAurora Twinkle
07/17/2024, 10:08 AMArjun Kishore
07/18/2024, 1:29 AMSilvia Santillan Nava
07/18/2024, 4:02 PMAnshul Singh
07/19/2024, 4:39 AM__change_events
topic is not present in zookeeper, causing failure while creating reader consumer on it. The namespace is present in 2 clusters. In one cluster everything works, issue is in other geo-replicated cluster.
Failed to create consumer: consumerId=13, No such ledger exists on Metadata Server - ledger=26332633 - operation=Failed to open ledger
Verified that /ledgers/00/2633/L2633 znode is not present.
What things I have tried so far:
• Tried removing the __change_events by removing the clusters from namespace (+ making sure its znode is not present in /managed-ledger) and adding it back. So that it recreates a new ledger and doesn't refer to the old one (26336488). This didn't mitigate the issue. When __change_events topic got recreated in /managed-ledger zk path its still referring to old ledgerId.
• Trying to find how bookkeeper .log
file maps to a ledgerId. This might help in recreating the ledgerMetadata znode manually. Not entirely sure though about this approach.
Any other suggested approach I look into?Chittaranjan Sardar
07/19/2024, 9:29 AMorg.apache.pulsar.broker.authentication.AuthenticationProvider
as mentioned at https://pulsar.apache.org/docs/3.3.x/security-extending/
How I can do required setting in conf/broker.conf
of Broker/Proxy while using this Helm Chart?antliu
07/22/2024, 2:14 AMChittaranjan Sardar
07/22/2024, 3:13 AMigor.b
07/22/2024, 6:22 AMsbourke
07/22/2024, 2:41 PMDavid K
07/22/2024, 5:35 PMKamil Chociej
07/23/2024, 8:47 AM