2019-03-25 09:49:45 UTC - Laurent Chriqui: I just tried that approach and it led me to the same error message... Problem with Boost ? ---- 2019-03-25 09:59:29 UTC - Laurent Chriqui: I am running Python 3.7.2 on Mac Os 10.14.3 ---- 2019-03-25 10:46:07 UTC - Ganga Lakshmanasamy: Hi, One of the messages in topic is failing due to data issues. Is there a way to remove that message from topic. The consumer is not picking up the next messages in queue since the first one is failing. ---- 2019-03-25 12:12:03 UTC - Mark Marijnissen: Q: is it possible to set message key in a python publisher for topic compaction? Can't find anything in source code or docs about this. A: Partition-key, which is hashed to assign topic partitions, is also used for compaction. ---- 2019-03-25 13:15:43 UTC - Chris Bartholomew: @Ganga Lakshmanasamy You can skip messages in a subscription. To skip the just next message on a subscription, use ```pulsar-admin topics skip <topic> -s <subscription> -n 1```, where n is the number of messages to skip. ---- 2019-03-25 13:21:38 UTC - Ganga Lakshmanasamy: Thanks @Chris Bartholomew Let me check ---- 2019-03-25 14:14:05 UTC - Samuel Sun: Hi , one question for producerid and consumerid, are they unique for each topic ? e.g. for one topic, we never have two producers with same producerid ? ---- 2019-03-25 14:54:16 UTC - Stefan Rösch: @Stefan Rösch has joined the channel ---- 2019-03-25 15:46:48 UTC - Stefan Rösch: Hi! Maybe someone can answer me a question. Unfortunately I could not find anything in the docs. Q: Which authentication mechanisms are supported by the WebSocketApi? ---- 2019-03-25 16:16:14 UTC - Laurent Chriqui: One of my colleagues was able to compile it, so I tested it and it works. I have one question, when does the timeout delay start? producing or consuming of the message ? ---- 2019-03-25 16:47:44 UTC - Matteo Merli: @Stefan Rösch All the available auth methods should work with WebSocket ---- 2019-03-25 16:49:33 UTC - Emma Pollum: When batching messages, how are they counted in the backlog? Say if i batch 100 messages, will I see 100 messages in backlog or just 1? ---- 2019-03-25 16:49:50 UTC - Emma Pollum: (assuming there is a subscription to hold the backlog, and no consumer actively reading the subscription) ---- 2019-03-25 17:08:53 UTC - Matteo Merli: @Mark Marijnissen When calling `producer.send()` you can specify the `partition_key` as an argument
<https://pulsar.apache.org/api/python/#pulsar.Producer.send> ---- 2019-03-25 17:11:25 UTC - Matteo Merli: @Samuel Sun The producer/consumer ids are used within the context of a single TCP connection. They are basically shortcuts to refer to a particular producers. From a broker’s perspective, there could be different producers with same producer id in different connections. There are also other ways to track producers/consumer, like “producerName” or “consumerName” ---- 2019-03-25 17:12:21 UTC - Matteo Merli: The current behavior of reported backlog, reports the number of BookKeeper entries (or Pulsar batches) instead of the actual number of messages ---- 2019-03-25 17:13:30 UTC - Matteo Merli: There was some work item to improve that with at least an estimate of the number of actual messages in the backlog, though getting the exact number can be tricky. ---- 2019-03-25 17:32:23 UTC - Matteo Merli: The ack timeout is triggered from the moment the message is received the application. eg: when doing `consumer.receive()`. Similarly that apply to functions ---- 2019-03-25 17:36:27 UTC - Emma Pollum: Rough! Is it possible to force pulsar to batch on a certain message size (rather than max # of messages or max time?) ---- 2019-03-25 17:36:37 UTC - Emma Pollum: That way I know each entry contains N messages? ---- 2019-03-25 17:37:16 UTC - Matteo Merli: Yes, there’s <https://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder.html#batchingMaxMessages-int-> ---- 2019-03-25 17:37:39 UTC - Matteo Merli: that, and `producer.flush()` ---- 2019-03-25 17:37:55 UTC - Matteo Merli: or you can disable batching all-together ---- 2019-03-25 17:38:10 UTC - Matteo Merli: <https://pulsar.apache.org/api/client/org/apache/pulsar/client/api/ProducerBuilder.html#enableBatching-boolean-> ---- 2019-03-25 17:54:07 UTC - Emma Pollum: Thank you! ---- 2019-03-25 21:20:45 UTC - Ben S: Is it possible to get an event when a subscriber subscribes to a new topic, and then create a producer for the new topic ad-hoc? ---- 2019-03-25 21:40:46 UTC - Matteo Merli: Not directly, though you can build that on top of topics. For example by maintaining a notification topic. We have in the roadmap to add support for “system” topics as a way to get applications to be able to get this kind of notifications (new topic, new subscription, etc…) ---- 2019-03-25 22:09:53 UTC - Zarrar: hello guys, I am having issues starting functions worker, I believe I am hitting the issue below, is there any work around <https://github.com/apache/pulsar/issues/3715> ---- 2019-03-25 22:11:06 UTC - Grant Wu: Revert to 2.2.1 is my “workaround” :stuck_out_tongue: ---- 2019-03-25 22:11:46 UTC - Zarrar: ok, I just start exploring pulsar on k8s ---- 2019-03-25 22:12:36 UTC - Zarrar: does 2.2.1 supports kubernetesContainerFactory? ---- 2019-03-25 22:12:48 UTC - Grant Wu: I don’t know ---- 2019-03-25 22:13:46 UTC - Zarrar: ok thanks, I will downgrade and see if it resolves the problem ---- 2019-03-25 22:23:45 UTC - Sree Vaddi: <https://www.infoworld.com/article/3379120/pubsub-messaging-apache-kafka-vs-apache-pulsar.html> thumbsup_all : Sree Vaddi, jia zhai, Karthik Ramasamy ---- 2019-03-25 22:50:01 UTC - Ben S: This would be very helpful for my current application ---- 2019-03-26 02:35:38 UTC - Sree Vaddi: we have a linkedin group, now. please join. <https://www.linkedin.com/groups/8696103/> +1 : Remco Verhoef ---- 2019-03-26 02:58:05 UTC - jia zhai: :+1: ---- 2019-03-26 07:11:51 UTC - Stefan Rösch: Oh thats great. Is there somewhere a Documentation on how to use the WebSocket with Tokens for Client Auth? (JWT) ---- 2019-03-26 08:00:34 UTC - Stefan Rösch: Is there a Roadmap for the NodeJs Client? ---- 2019-03-26 08:07:02 UTC - Ali Ahmed: not one fleshed out but here are current issues being tracked ---- 2019-03-26 08:07:03 UTC - Ali Ahmed: <https://github.com/apache/pulsar-client-node/issues> ---- 2019-03-26 08:40:42 UTC - Remco Verhoef: @Remco Verhoef has joined the channel ---- 2019-03-26 08:44:50 UTC - Ali Ahmed: @Remco Verhoef :wave: ---- 2019-03-26 08:46:46 UTC - Stefan Rösch: Thank you. ---- 2019-03-26 08:57:01 UTC - Remco Verhoef: hi all! ---- 2019-03-26 08:57:20 UTC - Ali Ahmed: Hello ----
