2020-04-10 09:44:13 UTC - Subash Kunjupillai: Thanks Raman :+1: ---- 2020-04-10 09:58:13 UTC - Alessandro R.: Hello, is it possibile to configure a connector using json instead of yaml? There is an hint here: <https://pulsar.apache.org/docs/en/io-quickstart/> . but when I try to create a sink with the Admin REST API I get this error “Unsupported Media Type” ---- 2020-04-10 10:13:50 UTC - Alessandro R.: Looks like there is documentation that I’ve found through google, but not from the website. <https://pulsar.apache.org/sink-rest-api/#operation/registerSink> ---- 2020-04-10 12:25:07 UTC - Ryan Slominski: Does SourceContext.getInstanceId() always return a number between 1 and SourceContext.getNumInstances()? If not, how does the running instance know which number it is? ---- 2020-04-10 13:49:36 UTC - michael.colson: It will be a point-lookup query. Like a join with a common key. I would like to be able to use some kind of predicate pushdown as i know the event time + the key ---- 2020-04-10 14:38:32 UTC - Subash Kunjupillai: Hi, As we already have a Kafka application, I'm exploring on <https://pulsar.apache.org/docs/en/adaptors-kafka/|Kafka Adaptor> provided by Pulsar. So that, we would be able to port our our application AS-IS to Pulsar. In order to test the performance between Pulsar API and Kafka Adaptor , I created sample producer applications (attached) for both. I was expecting no big performance deviation, but I'm surprised to see that Pulsar API is performing lower than Kafka Adaptor. 1. SimpleKafkaProducer (Using Kafka Adptor ), produced 100000 records in 4 seconds. 2. SimpleProducer (Using Pulsar native API), produced 100000 records in 459 seconds. Can someone please help me to understand why I'm seeing a difference in performance as both the applications are running on top of the same Pulsar cluster. ---- 2020-04-10 15:25:06 UTC - Matteo Merli: In Kafka api, producer.send() returns a future. When it returns, the message is not published yet.
The equivalent in Pulsar, is to use senAsync() ---- 2020-04-10 15:45:03 UTC - Subash Kunjupillai: Wow.. Thanks! That answers my query. I should have gone through the API document :slightly_smiling_face: ---- 2020-04-10 16:13:09 UTC - Sijie Guo: Currently it doesn’t support readCompact yet ---- 2020-04-10 16:13:19 UTC - Sijie Guo: Can you create an issue for us? ---- 2020-04-10 18:22:15 UTC - CARREAU Clement: @CARREAU Clement has joined the channel ---- 2020-04-10 18:25:33 UTC - CARREAU Clement: Hi, I'm also interested in the answer ! @Sijie Guo ---- 2020-04-10 19:38:39 UTC - Phil Barila: @Phil Barila has joined the channel ---- 2020-04-10 23:18:12 UTC - Tolulope Awode: @Tolulope Awode has joined the channel ----
