2020-03-23 09:23:14 UTC - xue: Run Functions-worker separately，Configure Proxies for Functions-workers，functionWorkerWebServiceURL/functionWorkerWebServiceURLTLS like this，Port that discovery service listen on 8082, then start pulsar proxy，but curl <http://hostname:8082/admin/v2/worker/cluster> ---- 2020-03-23 09:24:37 UTC - xue: ---- 2020-03-23 09:25:14 UTC - xue: {"reason":"Function worker service is not done initializing. Please try again in a little while."} ---- 2020-03-23 09:52:15 UTC - hhiroshell: @hhiroshell has joined the channel ---- 2020-03-23 10:01:22 UTC - sbourke: Hi, does anyone know if swagger.json is served locally by the admin web service, and if so the path it's located at? ---- 2020-03-23 10:03:10 UTC - Ron Farkash: @Ron Farkash has joined the channel ---- 2020-03-23 10:08:38 UTC - Ron Farkash: As an administrator I would like to limit my clients' produce/consume rate, I found it a bit hard to understand from the documentation on how I would go about doing that. Could someone provide me with a clear explaination on what are Pulsar's capabilities when it comes to controlling quota as an admin (when my producers and consumers are not directly under my control and I wouldn't want them to deplete my resources)? ---- 2020-03-23 12:07:54 UTC - Horacio Gonzalez: @Horacio Gonzalez has joined the channel ---- 2020-03-23 12:15:57 UTC - Konstantinos Papalias: what's the new structure @Dennis Yung, just curious while developing on a previous version, still try to understand the changes required for 2.5.0 (if any) ---- 2020-03-23 14:06:48 UTC - Ming: There are dozen throttling parameters <https://github.com/apache/pulsar/blob/master/conf/broker.conf#L223> ---- 2020-03-23 16:15:25 UTC - Ron Farkash: @Ming is it possible even per consumer/producer? ---- 2020-03-23 20:05:37 UTC - Alex Yaroslavsky: Hi, is it possible to use functions with encryption? From the function API it doesn't seem to be possible or am I missing something?. I don't even need the function to decrypt the data, just forward it as is to a different topic. ---- 2020-03-23 20:35:30 UTC - Aaron Stockton: so does acking a message on an exclusive / failover subscription have any affect? ---- 2020-03-23 21:03:45 UTC - tcourdy: quick question. when using k8s runtime for functions are the logs of the functions still stored in the broker pod? ---- 2020-03-23 21:06:06 UTC - chris: with the k8s runtime logs go to stdout on the function pods ---- 2020-03-23 21:09:30 UTC - tcourdy: so can that be configured to be routed to the broker pods via the `functions_worker.yaml` somehow (<https://pulsar.apache.org/docs/ja/2.4.0/functions-runtime/#configure-kubernetes-runtime>)? Otherwise I imagine those logs will be ephemeral? ---- 2020-03-23 21:15:00 UTC - tcourdy: or maybe its sounding like if i want persistent logs the best approach is to modify my functions to write the log output to a log topic and then having something else consume that and write it to somewhere persistent? (<https://pulsar.apache.org/docs/en/functions-debug/#use-log-topic>) ---- 2020-03-23 21:15:44 UTC - chris: that is one option. also the pods logs are around on the host far a while as long as the pod is running ---- 2020-03-23 21:16:17 UTC - chris: also we had success using this <https://grafana.com/oss/loki/> ---- 2020-03-24 00:55:35 UTC - David Kjerrumgaard: If you have a function that returns a type, e.g. `implements Function<POJO1, POJO2>` is there a way to include some properties in the response record? Or should I do something like the following? `ctx.newOutputMessage(creditCardTopic, AvroSchema._of_(POJO2.*class*)).properties(ctx.getCurrentRecord().getProperties()).value(pojo2).sendAsync();` ---- 2020-03-24 01:36:09 UTC - tuteng: hi, Have you changed the parameter username? in our initialization environment, this parameter is the same as that of database initialization and cannot be modified. `docker run -it -p 9527:9527 -e REDIRECT_HOST=<http://192.168.0.104> -e REDIRECT_PORT=9527 -e DRIVER_CLASS_NAME=org.postgresql.Driver -e URL='jdbc:<postgresql://127.0.0.1:5432/pulsar_manager>' -e USERNAME=pulsar -e PASSWORD=pulsar -e LOG_LEVEL=DEBUG -v $PWD:/data apachepulsar/pulsar-manager:v0.1.0 /bin/sh` ---- 2020-03-24 01:37:58 UTC - tuteng: The current user name and password are configured to connect to the database. The current default user name and password are pulsar and pulsar. ---- 2020-03-24 01:38:10 UTC - tuteng: @Pradeesh ---- 2020-03-24 02:57:12 UTC - Dennis Yung: instead of commenting out each untime env options, there is a new functionRuntimeFactoryClassName param, with configs for each runtime grouped under functionRuntimeFactoryConfigs ---- 2020-03-24 06:41:06 UTC - Abhilash Mandaliya: hi I have developed my own sink connector and it is working fine. But it is not working on 2 pulsar brokers. I am running create command on 1st node like below which works fine and runs the connector. ```pulsar-admin sinks create \ --tenant public \ --namespace default \ --name my-sink \ --sink-type my-sink-type \ --inputs players \ --sink-config-file my-sink-connector-config.yml``` But on the second node, I am trying to run start command to start my sink connector.
```pulsar-admin sinks start \ --tenant public \ --namespace default \ --name my-sink``` It doesn’t start and gives the error: *Operation not permitted* *Reason: Operation not permitted* Can anyone help here? ----
