Slack digest for #dev - 2020-10-29

2020-10-28 13:12:31 UTC - Florentin Dubois: @Florentin Dubois has left the channel 2020-10-28 15:01:41 UTC - Brendan Lynch: @Brendan Lynch has joined the channel 2020-10-28 16:21:15 UTC - Anup Ghatage: fair enough..

Slack digest for #dev - 2020-10-28

2020-10-27 13:49:15 UTC - Lari Hotari: The flakiness problem is really bad. It's hard to get a pass. It takes 5-6 attempts in many cases to get a PR to pass. 2020-10-27 13:49:41 UTC - Lari Hotari: I created an issue for InactiveTopicDeleteTest:

Slack digest for #dev - 2020-10-27

2020-10-26 12:59:16 UTC - jia zhai: @Sijie Guo @Anup Ghatage right, there is no specific reason for this. It seems be more related to the project building, we may need to config the profile to build different bc type. but this seems a little hard in maven:joy:. It would be helpful, if anyone wo

Slack digest for #dev - 2020-10-26

2020-10-25 11:40:30 UTC - Lari Hotari: InactiveTopicDeleteTest and TopicDuplicationTest are also failing very often. The logs show 500 server error happening for TopicDuplicationTest, so it might be an actual problem and not just a flaky tests. In InactiveTopicDeleteTest, I can see the usage of

Slack digest for #dev - 2020-10-25

2020-10-24 11:25:15 UTC - Lari Hotari: The grpc upgrade was reverted. I have pushed a PR to fix the bug in the Github Flow used in Pulsar CI which caused the tests to be skipped for the grpc upgrade PR: . Once that is merged, I guess the a P

Slack digest for #dev - 2020-10-24

2020-10-23 10:25:41 UTC - Lari Hotari: The CI test flakiness is pretty bad. For example, PR #8326 failed 5 times in a row and I had to resume each time with "/pulsarbot run-failure-checks". One test that fails every often is PrometheusMetricsTest. @Devin G. Bost has reported a few issues before

Slack digest for #dev - 2020-10-23

2020-10-22 19:24:05 UTC - Gautam Kumar: it is fixed now

Slack digest for #dev - 2020-10-22

2020-10-21 09:28:48 UTC - Ben: . Thanks for the help. 2020-10-21 10:19:56 UTC - N Navin: My requirement is to cleanup the namespace which is not empty. Currently i have to manually delete each topic under the namespace and finally delete the name

Slack digest for #dev - 2020-10-21

2020-10-20 14:35:16 UTC - Ben: I think I might be seeing a potential memory leak in the C client, and before I report it I thought I would ask here to see if it's a known issue or if I'm misunderstanding something. I'm actually using the client via a go app. When sending large numbers (hundreds

Slack digest for #dev - 2020-10-20

2020-10-19 12:32:54 UTC - Lari Hotari: @Addison Higham When does the cherry picking onto the release branches happen? I see some commits cherry picked in . In particular, I'd be interested in testing the fix for

Slack digest for #dev - 2020-10-14

2020-10-13 14:07:02 UTC - Sijie Guo: That is correct +1 : dionjansen

Slack digest for #dev - 2020-10-13

2020-10-13 04:17:57 UTC - Sijie Guo: You should use `num_messages_in_batch` in the metadata 2020-10-13 06:52:19 UTC - dionjansen: @Sijie Guo so is the following correct? The metadata property `num_messages_in_batch` is optional so if  `num_messages_in_batch` is set (whether to 1 or a number

Slack digest for #dev - 2020-10-12

2020-10-12 08:04:09 UTC - dionjansen: @dionjansen has joined the channel 2020-10-12 08:09:21 UTC - dionjansen: Hi, does anyone know how to differentiate a payload containing batched messages from non-batched messages using Pulsar binary protocol on the consumer side? Should `num_messages_in_

Slack digest for #dev - 2020-10-10

2020-10-09 18:30:05 UTC - Arushi Sharma: @Arushi Sharma has joined the channel

Slack digest for #dev - 2020-10-09

2020-10-09 00:06:00 UTC - jia zhai: marked it as 2.6.2, so it can be cherry-picked into release 2.6.2 2020-10-09 03:40:43 UTC - Lari Hotari: Ok great. btw. How does the cherry-picking happen? Does someone process all pending ones frequently? 2020-10-09 03:50:26 UTC - Addison Higham: Whe

Slack digest for #dev - 2020-10-08

2020-10-07 16:26:26 UTC - Rich Adams: Does anyone know why pulsar-sql creates its ReadOnlyCursors with a default ManagedLedgerConfig rather than the configured ManagedLedgerConfig? I am running into issues where queries including a predicate with `__publish_time__` are failing with a `ManagedLe

Slack digest for #dev - 2020-10-06

2020-10-05 14:07:43 UTC - Ravi Shah: Hi Team - 2020-10-05 14:08:32 UTC - Ravi Shah: I can see support for pullMode in the websocket based consumer, Do we have same pullMode based support in Node.js SDk(npm)? 2020-10-06 07:07:22 UTC - wim de keyzer: @wim de keyzer has joined the channel

Slack digest for #dev - 2020-10-03

2020-10-02 16:56:43 UTC - Claude: @Claude has joined the channel 2020-10-02 22:04:44 UTC - Rich Adams: Any tips for getting the SQL integration test running locally? I can see it’s failing on my pull request but not quite sure what the best way to hack on it is. 2020-10-02 22:11:28 UTC

Slack digest for #dev - 2020-10-01

2020-09-30 10:19:03 UTC - Milos Matijasevic: @Milos Matijasevic has joined the channel 2020-09-30 18:42:38 UTC - Lari Hotari: Thank you @jia zhai for reviewing and merging the PRs. What is the process to back port the fixes to 2.6 branch? It would be nice to get the fixes in 2.6.2 . 20

Slack digest for #dev - 2020-09-30

2020-09-29 09:51:35 UTC - Lari Hotari: There were 2 more locations where ConsumerImpl instances were leaked when using the Reader API. Fixed in this PR: 2020-09-29 15:41:38 UTC - Addison Higham: :bow: thanks @Lari Hotari I sent that second one on

Slack digest for #dev - 2020-09-29

2020-09-28 11:13:28 UTC - Lari Hotari: @Addison Higham thanks for the suggestion. I looked into the way it's done in BrokerService. However since ClientCnx already had a way to handle timeouts for "ordinary" command requests, I decided to extend that to support also the other type of requests th

Slack digest for #dev - 2020-09-28

2020-09-28 05:54:21 UTC - Gabriel Ciuloaica: @Gabriel Ciuloaica has joined the channel

Slack digest for #dev - 2020-09-26

2020-09-25 13:11:09 UTC - Guillaume: Hi, Periodically all of my subscribers and consumers get disconnected and I found these in the logs: 11:52:24.474 [GarbageCollectorThread-11-1] ERROR org.apache.bookkeeper.bookie.ScanAndCompareGarbageCollector - Exception when iterating through the ledgers t

Slack digest for #dev - 2020-09-25

2020-09-24 13:27:44 UTC - Ravi Shah: Hi Guys, I can see there is a support for unsubscribe method in Github repo for Node.js which is not released in 1.2.0 version on NPM. Is there any ETA for this to be released and available? 2020-09-24 15:24:58 UTC - Jim M.: ok, got this exception happen

Slack digest for #dev - 2020-09-24

2020-09-23 10:09:17 UTC - QW: @QW has joined the channel 2020-09-23 13:32:08 UTC - Gautam Lodhiya: Hello, I am facing some issue of frequent consumer disconnection and reconnection, due to which the consumer processing some message couldn’t ack and it gets re-enqueued directly on consumer d

Slack digest for #dev - 2020-09-23

2020-09-22 15:53:19 UTC - Sijie Guo: No progress yet. There are more interesting tasks to accomplish in Pulsar than removing zookeeper at this moment. 2020-09-22 18:31:08 UTC - Rich Adams: @Stepan Mazurov I think that PrestoSQL tries to maintain compatibility with the jdbc driver/server fro

Slack digest for #dev - 2020-09-22

2020-09-21 12:04:06 UTC - Vil: what is difference between auditorPeriodicBookieCheckInterval and auditorPeriodicCheckInterval ? 2020-09-21 12:05:10 UTC - Vil: and pulsar enables auto recovery in bookeeper yes or no by default? it is disabled in pulsar’s conf/broker.conf and in bookkeepers c

Slack digest for #dev - 2020-09-18

2020-09-17 16:58:32 UTC - Stepan Mazurov: are wire protocols different? 2020-09-17 23:57:55 UTC - Addison Higham: Hey, sorry @Jonathan Ellis I didn't see this till now, were you able to get this resolved? 2020-09-18 00:01:41 UTC - Addison Higham: that dependency is actually internal to

Slack digest for #dev - 2020-09-17

2020-09-16 13:17:05 UTC - sindhushree: Hi , we are using pulsar flink connector and getting the millions of offset in the trace logs .and leading to state restoration error . 2020-09-16 11:44:39.764 [Source: opr_event -> c9ee23b has remote state SubtaskState{operatorStateFromBackend=StateObjectCo

Slack digest for #dev - 2020-09-16

2020-09-15 13:48:19 UTC - Josh Perryman: @Josh Perryman has joined the channel 2020-09-15 14:02:06 UTC - Alexandre DUVAL: Oh topic reader can't be created on partitioned topics. So consume without ack? 2020-09-15 14:31:21 UTC - Vil: I think you can use it. but need to point the Reader t

Slack digest for #dev - 2020-09-15

2020-09-14 15:37:58 UTC - Enrico: @Enrico has joined the channel 2020-09-14 18:12:44 UTC - Devin G. Bost: Looks like Kafka is working on removing Zookeeper. They're talking about it at ApacheCon: (very bottom of page) @Jerry Peng @Matteo

Slack digest for #dev - 2020-09-11

2020-09-10 18:33:15 UTC - Ali Ahmed: @Sijie Guo @Matteo Merli can you please merge this mr +1 : Matteo Merli, Varghese C

Slack digest for #dev - 2020-09-10

2020-09-09 11:26:41 UTC - Gabriel Volpe: @Gabriel Volpe has joined the channel 2020-09-09 11:28:30 UTC - Gabriel Volpe: Is this the appropriate channel to ask questions about the protocol? I'll go ahead and ask here but feel free to point me to the right channel if this is not the one.

Slack digest for #dev - 2020-09-09

2020-09-08 16:55:33 UTC - Jarrod Johnson: I have a question about dead letter topics (if this is not the right channel to post in please let me know): Is the dead letter functionality compatible with partitioned topics? I have a sample app setup to test this and it seems everything works as expe

Slack digest for #dev - 2020-09-07

2020-09-07 02:09:14 UTC - aloyszhang: It seems there are some PR failed at `CI - Integration - Sql / sql` for the same reason. _`[ERROR] Tests run: 4, Failures: 2, Errors: 0, Skipped: 2, Time elapsed: 99.951 s <<< FAILURE! - in TestSuite`_ _`[ERROR] pulsar-test-suite(org.apache.pulsar.tests.in

Slack digest for #dev - 2020-09-06

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

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-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-03

2020-09-02 10:35:23 UTC - Jarrod Johnson: @Jarrod Johnson 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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-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-07-29

2020-07-28 19:52:43 UTC - Roy Tarantino: @Roy Tarantino 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-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-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-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-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-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-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-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-19

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

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-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-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-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-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-12

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

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-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-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-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-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-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-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-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-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-06-30

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

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-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-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-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-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-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-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-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-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-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-17

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

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

  1   2   3   4   5   >