2019-04-22 09:30:10 UTC - Yuvaraj Loganathan: Considering oracle stopped 
supporting java8 does pulsar works on openjdk 8 ? cc @Sijie Guo
----
2019-04-22 09:37:55 UTC - Ali Ahmed: yes pulsar works fine with openjdk 8
+1 : Yuvaraj Loganathan
----
2019-04-22 09:54:45 UTC - Sijie Guo: @Yuvaraj Loganathan yes
+1 : Yuvaraj Loganathan
----
2019-04-22 10:21:58 UTC - Samuel Sun: Hi, for Pulsar functions, do we have real 
cases/scenarios like below figure ? multiple topics as input , function process 
and output to multiple topics  ?
----
2019-04-22 13:59:24 UTC - Guy Feldman: one possible scenario is that you're 
using a pulsar function to serialize text events of similar type to avro. I 
think for multiple input topics you would need a stateful function to join 
records so maybe a more realistic case is the function stores state in a db.
----
2019-04-22 17:23:33 UTC - Ruud Kamphuis: Are there plans for a REST api to 
produce messages to a topic? Feels weird that it's only possible to produce 
over a websocket 
----
2019-04-22 18:20:07 UTC - Jon Bock: @Ruud Kamphuis Is in development.
----
2019-04-22 18:40:42 UTC - Sanjeev Kulkarni: @Samuel Sun A common scenario is 
joining a bunch of streams. Pulsar Functions with windowing allows you to do 
precisely this.
----
2019-04-22 18:41:26 UTC - Sanjeev Kulkarni: broker logs would greatly help here 
to figure out whats going on
----
2019-04-22 19:48:26 UTC - Sam Leung: Hmm thank you for letting me know about 
this upcoming feature. I can see how this could be related, but it doesn’t 
quite fit this particular use case.
----
2019-04-22 20:31:50 UTC - Devin G. Bost: I passed an integer value (1234) to 
the `configs` property of a `SinkConfig` object, and when I retrieved the value 
from Pulsar, the value came back as a floating point value ("1234.0").
I'm using the property to contain a port number.
Is this behavior intended?
----
2019-04-22 20:36:16 UTC - David Kjerrumgaard: @Devin G. Bost How did you 
retrieve the value?
----
2019-04-22 20:36:48 UTC - Devin G. Bost: `adminClient.sink().getSink(tenant, 
namespace, sink);`
(via Java Admin API)
----
2019-04-22 21:09:41 UTC - David Kjerrumgaard: @Devin G. Bost I think it is just 
a matter of how that API interprets the value vs. the sinkConfig object. One 
treats it as a float and the other as an int. Is the Sink working as expected 
w.r.t the port number.
----
2019-04-22 21:22:07 UTC - Sanjeev Kulkarni: @Guy Feldman you can use the state 
inside pulsar function to manage that state, no need to introduce another dep
----
2019-04-22 21:23:10 UTC - Sanjeev Kulkarni: @Devin G. Bost that was fixed post 
2.3.1. 
+1 : Devin G. Bost
----
2019-04-23 00:32:10 UTC - Samuel Sun: Thanks , got it 
----
2019-04-23 05:42:00 UTC - Viktor: @Viktor has joined the channel
----

Reply via email to