[GitHub] [pulsar-helm-chart] frankjkelly opened a new issue #173: Helm Chart does not allow us deploy more another Pulsar instance with the same name in a different namespaces

2021-11-08 Thread GitBox
frankjkelly opened a new issue #173: URL: https://github.com/apache/pulsar-helm-chart/issues/173 **Describe the bug** When we try to deploy two Pulsar instances in different K8S namespaces in the same K8S Cluster we get ``` 16:58:22 Error: rendered manifests contain a resourc

Re: [Discuss] Add the `sslTruststoreLocation` config parameter for KafkaSink/KafkaSourceConfig

2021-11-08 Thread Enrico Olivelli
ZhangJian, Il giorno lun 8 nov 2021 alle ore 15:25 ZhangJian He ha scritto: > ## background > Currently, as my business is an IoT platform which serves many companies. > We are trying to use pulsar functions to push messages to our customers' > kafka server. Here I face the problem, the KafkaSin

Re: [DISCUSSION] PIP-108: Add method to help user judge if consumer queue has message

2021-11-08 Thread Enrico Olivelli
Il giorno lun 8 nov 2021 alle ore 15:01 ZhangJian He ha scritto: > Hello, matteo, About my PIP 108, the reason I want to have method > `hasMessageInReceiverQueue` is that > We need to control consumer at different rate. For example, consumer A > 10msg/s, consumer B 100 msg/s > so I can't use the

[Discuss] Add the `sslTruststoreLocation` config parameter for KafkaSink/KafkaSourceConfig

2021-11-08 Thread ZhangJian He
## background Currently, as my business is an IoT platform which serves many companies. We are trying to use pulsar functions to push messages to our customers' kafka server. Here I face the problem, the KafkaSinkConfig can only receive the `sslTruststoreLocation`. And the Kafka Client now only sup

Re: [DISCUSSION] PIP-108: Add method to help user judge if consumer queue has message

2021-11-08 Thread ZhangJian He
Hello, matteo, About my PIP 108, the reason I want to have method `hasMessageInReceiverQueue` is that We need to control consumer at different rate. For example, consumer A 10msg/s, consumer B 100 msg/s so I can't use the `listener` mode. the `receive(0)` method will remove the message from queue.

Re: [VOTE] PIP 107: Introduce the chunk message ID

2021-11-08 Thread Hang Chen
+1 (binding) Thanks, Hang Enrico Olivelli 于2021年11月5日周五 下午6:52写道: > > +1 (binding) > > Enrico > > Il giorno ven 5 nov 2021 alle ore 11:52 PengHui Li ha > scritto: > > > +1 > > > > Thanks for the great work. > > > > -Penghui > > > > On Mon, Nov 1, 2021 at 10:25 AM Zike Yang > > wrote: > > > > >