Slack digest for #general - 2019-04-23

[Apache Pulsar Slack <ap...@gmail.com>]

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