Slack digest for #dev - 2020-05-05

2020-05-04 16:49:33 UTC - Addison Higham: what is recommended for PEPs: 1. start a discussions on the mailing list, ideally with a rough draft of the proposal as a google doc 2. have conversation and get some support from the community 3. promote it to a PEP Often times, when PEPs are proposed, i

Slack digest for #dev - 2020-05-06

2020-05-05 13:07:59 UTC - Nicolò Paganin: Hi @Sijie Guo, a question: is there a way to debug pulsar sources? We would like to give out contribute developing fetaures that are needed in our project. I found out a this page but there is not an answer. I

Slack digest for #dev - 2020-05-07

2020-05-06 11:02:36 UTC - Konstantinos Papalias: the one liners are usually the harder ones to spot :smile: 2020-05-06 16:01:11 UTC - Ricardo Ferreira: @Ricardo Ferreira has joined the channel

Slack digest for #dev - 2020-05-08

2020-05-07 17:56:15 UTC - Andrei Canta: @Andrei Canta has joined the channel 2020-05-07 20:49:10 UTC - David Kjerrumgaard: Encountering this error now when I upgraded to Pulsar 2.5.1. Does the build now include an invalid version of the `com.google.common.base.Preconditions` class? 2020

Slack digest for #dev - 2020-05-09

2020-05-08 18:53:47 UTC - Alex Yaroslavsky: maybe I'm missing something, but ... It seems that all (most?) function metadata (class FunctionMetaDataManager) is saved under public/functions and if I set a global defaultRetentionTimeInMinutes those topics start to clear out. At least this is the o

Slack digest for #dev - 2020-05-10

2020-05-09 20:41:14 UTC - Deepak Sah: @Deepak Sah has joined the channel 2020-05-09 20:48:19 UTC - Deepak Sah: I am trying to publish messages to a pulsar topic with multiple goroutines as producers using `SendAsync` method. I keep getting this warning `Got unexpected send receipt for messag

Slack digest for #dev - 2020-05-11

2020-05-10 13:41:38 UTC - Deepak Sah: I solved it, was a silly mistake on my side: +1 : David Kjerrumgaard

Slack digest for #dev - 2020-05-12

2020-05-11 13:49:31 UTC - ckdarby: @ckdarby has joined the channel 2020-05-11 16:53:34 UTC - Devin G. Bost: I was told about a major performance issue with Sinks involving Prometheus metrics. I'm attempting to get more information about it to put it in an issue report. 2020-05-11 18:08:

Slack digest for #dev - 2020-05-13

2020-05-13 04:07:49 UTC - Ankit Lohia: @Ankit Lohia has joined the channel

Slack digest for #dev - 2020-05-15

2020-05-14 23:30:14 UTC - Addison Higham: hrm, so, we are trying to make brokers recover quicker from a bookie failure in k8s and have found more data. What we previously thought was happening: a bookie failed, it was removed and re-added and resolved to the old IP address due to DNS caching. T

Slack digest for #dev - 2020-05-16

2020-05-15 18:53:02 UTC - Sijie Guo: @Addison Higham - the PCBC pool in bookkeeper client is keyed by bookie id. so in k8s, it is the hostname + port. Currernt implement relies on netty (which relies on OS) telling the client that a connection is broken. So when the client detects the connection

Slack digest for #dev - 2020-05-20

2020-05-19 16:05:25 UTC - Ravi Shah: Hi Guys, I am getting - java.util.concurrent.TimeoutException: Idle timeout expired: 30/30 ms I am using websocket based producer. Is there any way to set keepAlive or do a ping call to make socket alive? Or Can I set idle time to Infinite? 2020-

Slack digest for #dev - 2020-05-21

2020-05-20 09:22:49 UTC - jia zhai: ```webSocketSessionIdleTimeoutMillis``` You need this config above, try set and add it into your conf/broker.conf, or conf/websocket.conf 2020-05-20 09:23:25 UTC - jia zhai: opened an issue to ASF infa f

Slack digest for #dev - 2020-05-22

2020-05-21 09:16:46 UTC - Vladimir Shchur: Hi! I'm working on sequenceId support, noticed the following acknowledge response from the server for non-batched messages HighestSequenceId is passed from server as -1 while

Slack digest for #dev - 2020-05-23

2020-05-22 09:48:39 UTC - Vladimir Shchur: @Matteo Merli can you please comment on that? I see it was your comment in the code 2020-05-22 09:52:29 UTC - Vladimir Shchur: @Penghui Li would you mind giving your thoughts on that? 2020-05-22 10:10:40 UTC - Penghui Li: Ok, looks the broker s

Slack digest for #dev - 2020-05-24

2020-05-23 15:58:20 UTC - Jarrod Johnson: :man-facepalming:Thanks, @Sijie Guo, that did the trick!

Slack digest for #dev - 2020-05-26

2020-05-25 17:08:25 UTC - Guillaume B: @Guillaume B has joined the channel 2020-05-26 02:21:50 UTC - feynmanlin: @feynmanlin has joined the channel

Slack digest for #dev - 2020-05-27

2020-05-26 16:02:38 UTC - Matthew Follegot: @Matthew Follegot has joined the channel 2020-05-26 17:03:52 UTC - Matthew Follegot: hi there! I just merged the latest from `master` on a feature branch and when I run `mvn test` I get some failed tests, here is some sample output: ```[INFO] Rea

Slack digest for #dev - 2020-05-28

2020-05-27 18:50:18 UTC - Addison Higham: so small update to this issue ^^ changing os level keep alive does fix the issue. When a bookie gets rescheduled, the time for a broker to be happy is just how fast keep alive. On k8s (or anywhere really), it is a bit of pain to mess with those settings

Slack digest for #dev - 2020-05-29

2020-05-28 15:01:23 UTC - Paul Wagner: @Paul Wagner has joined the channel 2020-05-29 00:02:07 UTC - Matteo Merli: > Sounds like the best path would be to implement a heartbeat in the connections to bookkeeper and to kill sockets if heartbeats fail Yes, I'd recommend that way in any case.

Slack digest for #dev - 2020-05-30

2020-05-29 09:33:14 UTC - Alex Yaroslavsky: Ok. modified the python files on the workers to disable batching and it works :slightly_smiling_face: 2020-05-29 16:04:00 UTC - Sijie Guo: cool

Slack digest for #dev - 2020-05-31

2020-05-30 20:38:42 UTC - Thomas Jamet: Hello, is there a way for a given topic to have different schemas applied to different messages (based for example on a property of the message)? I have different messages of different types which all relate to the same conversation and that I would like t

Slack digest for #dev - 2020-06-01

2020-05-31 18:27:52 UTC - David Kjerrumgaard: A topic can have multiple versions of a schema that are in effect during a specific period, e.g. schema evolution. However, it is intended to have only one in effect at a time. So if your message schema evolves slowly and in one direction then the c

Slack digest for #dev - 2020-06-02

2020-06-01 13:30:13 UTC - Ankush: @Ankush has joined the channel 2020-06-01 14:00:25 UTC - Lawal Azeez: @Lawal Azeez has joined the channel 2020-06-01 18:42:25 UTC - Thomas Jamet: Thanks for the reply. I was hoping for a mechanism to support different types of messages (i.e. different sc

Slack digest for #dev - 2020-06-03

2020-06-03 08:48:30 UTC - Gilles Barbier: @Thomas Jamet to obtain this result and keeping the benefits of using schema, I use an envelope: a message that contains a type and one of possible message, eg. ```{ "type": "record", "name": "AvroForEngineMessage", "namespace": "com.zenaton.j

Slack digest for #dev - 2020-06-04

2020-06-03 09:35:57 UTC - Thomas Jamet: Neat, tx! 2020-06-03 10:01:13 UTC - Penghui Li: The merge issue is fixed now in the master branch, if you have PRs that met this problem, please merge the master branch into your branch. Thanks. 2020-06-03 20:43:00 UTC - Addison Higham: okay, so w

Slack digest for #dev - 2020-06-06

2020-06-05 10:50:55 UTC - Damien Burke: @Damien Burke has joined the channel 2020-06-05 10:52:19 UTC - Damien Burke: Hi, is there a channel in here/else where for general pulsar design questions, or is that StackOverflow? Thanks 2020-06-05 10:53:43 UTC - Ali Ahmed: post those question in

Slack digest for #dev - 2020-06-07

2020-06-06 15:56:49 UTC - Amit Pal: @Amit Pal has joined the channel 2020-06-06 16:04:09 UTC - Amit Pal: is the transaction support ready in Pulsar? Where can I find the roadmap wrt transactions? 2020-06-06 23:30:59 UTC - Penghui Li: @Amit Pal Here is an issue for tracking transaction s

Slack digest for #dev - 2020-06-09

2020-06-08 12:39:58 UTC - Oliver Fenton: @Oliver Fenton has joined the channel 2020-06-08 13:52:53 UTC - charles: @charles has joined the channel 2020-06-08 14:08:56 UTC - Alex: @Alex has joined the channel 2020-06-08 23:39:13 UTC - Rakesh Arumalla: @Rakesh Arumalla has joined the c

Slack digest for #dev - 2020-06-10

2020-06-09 13:07:47 UTC - lucas amoroso: @lucas amoroso has joined the channel 2020-06-10 01:30:16 UTC - AaronRobert: @AaronRobert has joined the channel 2020-06-10 08:08:30 UTC - Igor: @Igor has joined the channel

Slack digest for #dev - 2020-06-11

2020-06-10 16:13:19 UTC - Atri Sharma: @Atri Sharma has joined the channel

Slack digest for #dev - 2020-06-12

2020-06-11 16:08:45 UTC - Enrico Olivelli: Hi I saw this post and it tells that Pulsar client is connecting to the bookies. Is it true?

Slack digest for #dev - 2020-06-13

2020-06-12 12:03:36 UTC - Vil: @Vil has joined the channel 2020-06-12 12:04:30 UTC - Vil: But doesn’t Pulsar Presto SQL work like this? Talking directly to Bookeeper? 2020-06-12 14:17:40 UTC - Anup Ghatage: @Anup Ghatage has joined the channel 2020-06-12 15:06:30 UTC - David Kjerrum

Slack digest for #dev - 2020-06-14

2020-06-13 12:35:12 UTC - megachucky: @megachucky has joined the channel 2020-06-14 06:41:57 UTC - Ali Ahmed: We should now be able to redo the cdc connector in pulsar

Slack digest for #dev - 2020-06-15

2020-06-14 15:46:15 UTC - sundar: Hi @Sijie Guo , if you remember my friend and I are college students who used pulsar for our final year project which is completed successfully, thanks for the advice and help. We now want to do our contributions to pulsar as it helped us a lot. This is the firs

Slack digest for #dev - 2020-06-16

2020-06-15 12:59:39 UTC - Alexandre DUVAL: Hi, did open an issue about that? 2020-06-15 12:59:42 UTC - Alexandre DUVAL: You* 2020-06-15 15:00:33 UTC - Cathy Thompson: @Cathy Thompson has joined the channel 2020-06-15 15:41:59 UTC - Addison Higham: it is already fixed in master (after

Slack digest for #dev - 2020-06-17

2020-06-17 09:04:49 UTC - Adrienn Tordai: @Adrienn Tordai has joined the channel

Slack digest for #dev - 2020-06-18

2020-06-17 15:07:12 UTC - Chris Herzog: @Chris Herzog has joined the channel 2020-06-17 16:17:58 UTC - Leonard Ge: @Leonard Ge has joined the channel 2020-06-17 17:59:36 UTC - Pedro Cardoso: @Sijie Guo Is the blog post out? I'm also very interested in hearing Pulsar's version. 2020-

Slack digest for #dev - 2020-06-19

2020-06-18 09:16:18 UTC - Charvak Patel: @Charvak Patel has joined the channel 2020-06-18 09:17:31 UTC - Charvak Patel: This does need some fixes, I tried to run benchmark and failed. Many version fixes to make sure it runs with new terraform plus Pulsar version also needs a bump 2020-0

Slack digest for #dev - 2020-06-20

2020-06-19 19:18:59 UTC - matt_innerspace.io: what are the best practices for updating java functions (jars) without interrupting overall processing, and without interrupting existing function executions? i.e. update the function after the next function execution completes, etc.

Slack digest for #dev - 2020-06-22

2020-06-21 12:47:08 UTC - Konstantinos Papalias: I guess even if it interrupts the current execution, it would resume from where it was left, re-consuming the last message and reprocess it. Otherwise you may want to `stop` all instances before upgrading with

Slack digest for #dev - 2020-06-23

2020-06-22 11:10:24 UTC - Charvak Patel: It doesnt solve the issue of the clients being stuck after topic creation. Once I figure that out will submit 2020-06-22 14:55:30 UTC - matt_innerspace.io: if i subscribe to multiple topics for a single function, how do 'processing guarantees' affect

Slack digest for #dev - 2020-06-24

2020-06-23 12:27:19 UTC - testinglab89: 2020-06-23 14:06:59 UTC - sundar: Hello all, I am trying to write test for pulsarfunction- localrun module more specifically localrunner.java. Here there is an import error, org.apache.pulsar.functions.proto.Function Which says "cannot resolve symbol

Slack digest for #dev - 2020-06-25

2020-06-24 10:44:48 UTC - Jermaine Oppong: @Jermaine Oppong has joined the channel 2020-06-24 14:51:30 UTC - Addison Higham: @Alex Yaroslavsky the auth data is currently pretty much used just in establishing clients/producers/consumers, curious what you use case is 2020-06-24 16:19:03

Slack digest for #dev - 2020-06-26

2020-06-25 13:57:34 UTC - Daniel Ferreira Jorge: @Daniel Ferreira Jorge has joined the channel 2020-06-26 08:52:19 UTC - Patrik Kleindl: @Matteo Merli Listening to the presentations from the Pulsar Summit (great work btw) you mention the Event Storage API that allows direct access on Bookke

Slack digest for #dev - 2020-06-27

2020-06-26 16:24:10 UTC - Alan Kittel: @Alan Kittel has joined the channel 2020-06-26 21:40:23 UTC - Devin G. Bost: Has anyone else run into issues with function load balancing with 2.5.2? 2020-06-26 21:41:52 UTC - Jerry Peng: Can you provide some more detail on the issue? 2020-06-

Slack digest for #dev - 2020-06-29

2020-06-29 07:55:42 UTC - Jonas Kint: @Jonas Kint has joined the channel

Slack digest for #dev - 2020-06-30

2020-06-29 20:36:40 UTC - Varghese C: @Varghese C has joined the channel

Slack digest for #dev - 2020-07-01

2020-06-30 16:59:34 UTC - Joshua Eric: @Joshua Eric has joined the channel 2020-07-01 01:02:59 UTC - Hao Zhang: @Hao Zhang has joined the channel 2020-07-01 01:12:20 UTC - huzongtang: @huzongtang has joined the channel

Slack digest for #dev - 2020-07-02

2020-07-01 22:05:01 UTC - Devin G. Bost: Does anyone have a bare-minimum docker image for running a Pulsar client (that they’d be willing to share)? 2020-07-01 23:03:47 UTC - Addison Higham: as in pulsar-client the java command? (I don't have one, but just for clarification :slightly_smiling

Slack digest for #dev - 2020-07-03

2020-07-02 18:42:26 UTC - Devin G. Bost: I’m looking for Go more specifically. Sorry, I was vague haha 2020-07-02 23:24:34 UTC - Tamer: 2020-07-02 23:25:59 UTC - Tamer: This what I use in the

Slack digest for #dev - 2020-07-06

2020-07-05 09:45:18 UTC - Charvak Patel: Has anyone faced issues while running Maven Build in parallel without tests? 2020-07-05 18:24:14 UTC - Sijie Guo: What is the issue you encountered?

Slack digest for #dev - 2020-07-07

2020-07-06 09:35:38 UTC - sindhushree: How to update a schema for topic using java client?admin.schema.createschema and delete schema is their . 2020-07-06 11:13:31 UTC - Kirill Kosenko: @Kirill Kosenko has joined the channel 2020-07-06 13:42:23 UTC - Charvak Patel: I am using this comma

Slack digest for #dev - 2020-07-08

2020-07-07 14:29:41 UTC - Vaibhav Aiyar: @Vaibhav Aiyar has joined the channel 2020-07-07 18:07:32 UTC - Avi Maslati: Hi Guys We currently have a very strange issue with shared_key subscription and partitioned topic, It looks like one partition is stuck, the backlog just grows and no consume

Slack digest for #dev - 2020-07-09

2020-07-08 14:24:39 UTC - Penghui Li: You can check the topic stats of the stucked partition, maybe there are some useful information. 2020-07-08 14:58:08 UTC - Avi Maslati: I already checked it it looks like all the consumers are connected but no one consume from this partition, msg rate is

Slack digest for #dev - 2020-07-10

2020-07-09 12:14:00 UTC - Gautam Kumar: @Gautam Kumar has joined the channel 2020-07-10 04:03:14 UTC - Jay/Fienna Liang: @Jay/Fienna Liang has joined the channel 2020-07-10 09:06:25 UTC - andrius.antipovas: @andrius.antipovas has joined the channel 2020-07-10 09:06:31 UTC - andrius

Slack digest for #dev - 2020-07-11

2020-07-10 09:38:40 UTC - Sijie Guo: Currently it is not enforced by schemas yet. It should be straightforward to add this enforcement. 2020-07-10 10:00:39 UTC - Ali Ahmed: are you asking how to filter messages in a consumer ? 2020-07-10 10:30:43 UTC - andrius.antipovas: Yes. I am savin

Slack digest for #dev - 2020-07-12

2020-07-11 20:54:48 UTC - Ethan Waldo: @Ethan Waldo has joined the channel

Slack digest for #dev - 2020-07-14

2020-07-13 14:27:42 UTC - Dave Miller: @Dave Miller has joined the channel 2020-07-13 17:20:52 UTC - Julius S: Hi All, would be interesting to talk within Pulsar community about the auto-scaling layer Pravega team are working on ontop of Bookeeper (at least that is how I currently understand

Slack digest for #dev - 2020-07-15

2020-07-14 12:59:11 UTC - jimmy xie: @jimmy xie has joined the channel 2020-07-14 15:33:04 UTC - Raman Gupta: @Pedro Cardoso one more useful reference, here is how adding and removing consumers with Key_Shared mode in Pulsar:

Slack digest for #dev - 2020-07-16

2020-07-15 10:15:51 UTC - Prashanth YV: @Prashanth YV has joined the channel 2020-07-15 12:33:45 UTC - andrius.antipovas: Hi, why Pulsar SQL cannot query the latest message? 2020-07-15 16:14:22 UTC - Joshua Eric: See more information here on a solution:

Slack digest for #dev - 2020-07-17

2020-07-16 16:03:27 UTC - Chris: I'm working on implementing a form of broker-side filtering of messages and could use a bit of help with pulsar internals. I've got basic filtering via byte pattern and regex working, but am stuck on decoding messages with schema inside the broker. I can get to b

Slack digest for #dev - 2020-07-18

2020-07-17 12:33:30 UTC - Imran: @Imran has joined the channel 2020-07-17 18:28:15 UTC - Addison Higham: @Chris I believe you can construct it from the `Topic` type 2020-07-17 18:28:32 UTC - Addison Higham: even if you have to parse the string topic at that point, probably still easier

Slack digest for #dev - 2020-07-19

2020-07-18 12:05:13 UTC - Livio Benčik: @Livio Benčik has joined the channel

Slack digest for #dev - 2020-07-21

2020-07-20 20:16:26 UTC - Devin G. Bost: Does anyone know where in the code I'd find the behavior of auto-ack? I'm trying to get a better understanding of when messages get acknowledged when auto-ack is enabled. 2020-07-20 20:25:10 UTC - Addison Higham: are you referring to functions auto a

Slack digest for #dev - 2020-07-22

2020-07-21 20:12:39 UTC - Kalyn Coose: Hello everyone! Can anyone help me with using the new maxMessageSize in Pulsar 2.6.0? We currently have 2.6.0 updated and set the maxMessageSize equal to 15 MB (15728640 bytes) and trying to send a ~13MB pdf document through Pulsar (pulsar-client-go). The p

Slack digest for #dev - 2020-07-23

2020-07-22 13:10:09 UTC - anbutech17: Hello All!.I'm new to apache pulsar.Could you please someone help me to setup the pulsar python setup in the pycharm IDE.i have google it and didn't get any information on this. it will be very helpful, if anyone share the steps to install the pulsar python

Slack digest for #dev - 2020-07-24

2020-07-23 14:42:45 UTC - James Wilson: @James Wilson has joined the channel 2020-07-23 17:11:19 UTC - Kalyn Coose: Is the Pulsar Java client supposed to log to console similar to the pure Go client? I get this: `ERROR StatusLogger No Log4j 2 configuration file found. Using default configura

Slack digest for #dev - 2020-07-25

2020-07-24 18:43:08 UTC - Varghese C: Thanks @Matteo Merli, I was able to run a test that CI runs, locally. The easiest way I could think of was to mount the pulsar repo folder into the docker container and run the CI command from the ci-*.yamls in github/workflows. > >docker run -it --name puls

Slack digest for #dev - 2020-07-26

2020-07-25 18:34:21 UTC - Varghese C: Hi Pulsar Devs, When I try and run a unit test in Eclipse using the Testng plugin - the resulting error is *Exception in thread "main" com.beust.jcommander.ParameterException: Unknown option: -testRealAWS.* It looks like its coming from the root pom. It star

Slack digest for #dev - 2020-07-27

2020-07-26 21:30:59 UTC - Brad Moore: @Brad Moore has joined the channel 2020-07-26 23:42:52 UTC - Kristi: @Kristi has joined the channel

Slack digest for #dev - 2020-07-28

2020-07-27 11:12:28 UTC - Ankur Jain: @Ankur Jain has joined the channel 2020-07-27 11:27:45 UTC - Ankur Jain: @Matteo Merli Is it possible for a replicated sub to not find relevant snapshot in the cache consistently such it will never be able to publish `ReplicatedSubscriptionsUpdate` ? Con

Slack digest for #dev - 2020-07-29

2020-07-28 19:52:43 UTC - Roy Tarantino: @Roy Tarantino has joined the channel

Slack digest for #dev - 2020-07-31

2020-07-30 22:46:08 UTC - Pratim SC: @Pratim SC has joined the channel 2020-07-31 08:34:34 UTC - Maximilian Michels: @Maximilian Michels has joined the channel

Slack digest for #dev - 2020-08-04

2020-08-03 13:12:24 UTC - Peter Newell: @Peter Newell has joined the channel 2020-08-03 21:02:19 UTC - Devin G. Bost: When I try to build the latest version of Pulsar, I'm getting this: ```[ERROR] Failed to execute goal on project pulsar-kafka-compat-client-test: Could not resolve dependenci

Slack digest for #dev - 2020-08-05

2020-08-04 13:59:13 UTC - Prashanth Tirupachur Vasanthakrishnan: @Devin G. Bost, how about running the failed tests individually? I get consistent failures when I run `mvn test -fn -e` from the parent directory. 2020-08-04 14:05:48 UTC - Prashanth Tirupachur Vasanthakrishnan: Just saw the o

Slack digest for #dev - 2020-08-06

2020-08-05 21:17:48 UTC - Devin G. Bost: It turns out that this was just due to the Maven version. 2020-08-06 06:57:27 UTC - Juha Ristolainen: @Juha Ristolainen has joined the channel

Slack digest for #dev - 2020-08-07

2020-08-06 14:35:45 UTC - Pramiti Guha: @Pramiti Guha has joined the channel 2020-08-06 14:40:21 UTC - Pramiti Guha: Hello everyone - need help on this error I am facing while developing a springboot consumer client for pulsar - I am using 'Exclusive' subscription type and when I deploy this

Slack digest for #dev - 2020-08-08

2020-08-07 12:23:00 UTC - Nicolas Ha: Looking at pulsar internals out of curiosity, in particular ConsumerImpl - I get that there is a receiver queue that gets re-filled from the broker and that the user can set how big it is. I don’t quite get why the queue would have to be emptied? 

Slack digest for #dev - 2020-08-10

2020-08-09 11:39:13 UTC - Avi Maslati: Hi Guys, We have a very strange issue with partitioned topics and shared_key subscriptions, every few days no messages are being consumed from some of the partitions and the backlog keeps growing, the issue persists until we resubscribe to the topic.

Slack digest for #dev - 2020-08-11

2020-08-10 09:17:49 UTC - Avi Maslati: opened 2020-08-10 11:16:26 UTC - Penghui Li: Thanks @Avi Maslati 2020-08-10 13:53:13 UTC - Enrico Olivelli: Hi Pulsar friends :slightly_smiling_face: In BookKeeper project I have filed a design documen

Slack digest for #dev - 2020-08-12

2020-08-11 10:27:04 UTC - Chris Wong: @Penghui Li Do we have `KEY_BASED` for `BatchBuilder` on *`C++`*? It’s kind of missing feature for `KEY_SHARED` mode. Can we have include it to `v2.6.1`? Really appreciate. 2020-08-11 10:56:22 UTC - Penghui Li: Key based batcher not support in CPP clien

Slack digest for #dev - 2020-08-13

2020-08-12 14:59:01 UTC - Caleb Epstein: @Caleb Epstein has joined the channel 2020-08-12 15:01:26 UTC - Caleb Epstein: I've got a open, but it has failed on one of the CI actions. I'm pretty sure the failure is wholly unrelated to my change

Slack digest for #dev - 2020-08-14

2020-08-13 10:14:49 UTC - moshe baruch: @moshe baruch has joined the channel 2020-08-13 10:15:15 UTC - moshe baruch: Hi Pulsar Team, We use pulsar SQL and we found that the Pulsar SQL is lacking the last message when querying pulsar topics. How can we solve this issue? This is a known issue

Slack digest for #dev - 2020-08-15

2020-08-14 11:36:42 UTC - Ravi Shah: Hi Team, How can I implement kafka keyed partition type functionality with pulsar? 2020-08-14 17:14:09 UTC - Sijie Guo: 2020-08-14 17:15:14 UTC - Sijie Guo: You

Slack digest for #dev - 2020-08-17

2020-08-16 10:15:44 UTC - moshe baruch: thank you! can you explain pls what is LAC? and what the reccomeneded value for bookkeeperExplicitLacIntervalInMills property? 2020-08-16 11:25:31 UTC - moshe baruch: Hi Pulsar Team, does pulsarSql support pagination? if yes, could you share the right

Slack digest for #dev - 2020-08-18

2020-08-17 21:32:43 UTC - Addison Higham: hrmm... sorry @moshe baruch I do not... I think that value should be fine, but just to make sure, are you adding that to `broker.conf` or did you only set it in dynamic settings? I am not sure if changing that in dynamic settings will work right away, as

Slack digest for #dev - 2020-08-19

2020-08-18 10:41:11 UTC - moshe baruch: @Sijie Guo it can be related to our presto version (0.206)? 2020-08-18 15:19:30 UTC - Alexandre DUVAL: Hi, there is plans around Spark SQL? 2020-08-18 15:34:16 UTC - Sijie Guo: No. This is related to bookies. You need to change bookie configuratio

Slack digest for #dev - 2020-08-20

2020-08-19 10:29:47 UTC - Arul: @Arul has joined the channel 2020-08-19 14:55:22 UTC - Maksym Domarev: @Maksym Domarev has joined the channel 2020-08-19 17:22:22 UTC - ckdarby: We've gone through the docs looking to see if Pulsar functions support a window method? Is it possible to have

Slack digest for #dev - 2020-08-21

2020-08-20 13:42:10 UTC - Lari Hotari: Are there any plans to upgrade the bundled Protobuf version within Pulsar? It's currently 3.5.1 (defined in ) which is pretty old. The reason why I'm asking is that I'm using Protobuf within Pu

Slack digest for #dev - 2020-08-22

2020-08-21 14:25:27 UTC - Nate Marshall: @Nate Marshall has joined the channel 2020-08-21 17:53:35 UTC - Arthur Alacar: @Arthur Alacar has joined the channel

Slack digest for #dev - 2020-08-25

2020-08-24 16:08:51 UTC - Jonathan Ellis: @Jonathan Ellis has joined the channel 2020-08-24 18:50:47 UTC - Stepan Mazurov: @Stepan Mazurov has joined the channel 2020-08-24 20:51:24 UTC - Alexandre DUVAL: It's not possible to create partitionned topics from java client? It requires admin

Slack digest for #dev - 2020-08-26

2020-08-26 07:00:21 UTC - Jerry Peng: btw pulsar-sql is broken is blocking CI. I think the reason is we haven't really been running the integration tests for it using the image built from the current version. Also upgrading to the new presto version completely broke things:

Slack digest for #dev - 2020-08-27

2020-08-27 06:29:59 UTC - Ravi Shah: Hi Guys- We are facing issue similar to "Consumer stop receive messages from broker()". We are using logstash and input plugin(). 2020-08-27 07:15:32 UTC

Slack digest for #dev - 2020-08-28

2020-08-27 13:36:54 UTC - jia zhai: Hi @Ravi Shah, which version of Pulsar are you using? 2020-08-27 13:41:28 UTC - Ravi Shah: 2.4.0 2020-08-27 17:03:03 UTC - Austin Bennett: @Austin Bennett has joined the channel

Slack digest for #dev - 2020-09-02

2020-09-01 17:29:38 UTC - Enrico Olivelli: Hi, what is the magic word to trigger rerun of failed tests ? 2020-09-01 17:33:16 UTC - Rajan Dhabalia: ```/pulsarbot run-failure-checks``` 2020-09-02 03:07:59 UTC - ly_sffy: @ly_sffy has joined the c

Slack digest for #dev - 2020-09-03

2020-09-02 10:35:23 UTC - Jarrod Johnson: @Jarrod Johnson has joined the channel

Slack digest for #dev - 2020-09-04

2020-09-03 17:10:37 UTC - Julius S: Saw this today, was published a few days ago: +1 : Vladimir Shchur 2020-09-03 17:11:43 UTC - Julius S: Author and analyser used are from

Slack digest for #dev - 2020-09-05

2020-09-04 16:29:04 UTC - Guillaume: @Guillaume has joined the channel

Slack digest for #dev - 2020-09-06

2020-09-05 15:10:35 UTC - Tadaki Sakai: @Tadaki Sakai has joined the channel

<    1   2   3   4   5   >