Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
Akara Sucharitakul
@akara
That's great! Let me take a look.
Varun Kumar
@vk9
Hi Can you please merge the PR paypal/squbs#709 and create a release ? I need it to use in my application
Akara Sucharitakul
@akara
We're close to releasing. But once merged, the snapshot should be immediately available upon build.
Varun Kumar
@vk9

Thanks @akara
But the snapshot version is available only for scala 2.12 and not for scala 2.11.
The sbt build in travis is not publishing for all versions in crossScalaVersion, the command should be as below in travis config

sbt ++$TRAVIS_SCALA_VERSION clean publishSigned

Gave a PR, can you please merge it to release the snapshot again ? Sorry about multiple commits and PR, sbt cross compile and travis is completely new for me.

Akara Sucharitakul
@akara
Thanks! Yes, we need to make sure snapshot is released for both Scala versions.
Akara Sucharitakul
@akara
squbs 0.12.0 snapshot for Scala 2.11 has been successfully published. Thanks @vk9!
Sherif Ebady
@sebady
I think we are ready for release of squbs 0.12.0. There is one PR though with Java Time duration #706 still open. Do we want to release w/o this PR or should we wait to resolve the remaining comments on the PR?
Akara Sucharitakul
@akara
That great @sebady, thank you very much! I think we can make it happen with that PR as it is really close to closing. @jiminhsieh would you be able to update the PR as requested? The other way is to take the PR as is and I'll follow up with another small PR.
Akara Sucharitakul
@akara
@sebady, since @jiminhsieh may be busy, I suggest merging this PR and I'll follow up with a PR doing the requested adjustments to keep the FiniteDuration as coarse grained as possible.
@anilgursel If you agree, please approve the PR. I'll approve on my side and then merge. Will issue a subsequent PR by today.
Anil Gursel
@anilgursel
sounds good
Done!
Akara Sucharitakul
@akara
Sounds like can't be merged without @jiminhsieh updating due to a merge conflict :-(
Let me see whether I can do something around it.
Akara Sucharitakul
@akara
Alright, I've converged the PR from @jiminhsieh with the Scala 2.11 changes and standardized the Duration conversions according to what is in scala-java8-compat (later versions than we can use). If @jiminhsieh. This is paypal/squbs#714. @agursel, @sebady, @crankydillo please consider. I'd normally rather wait for @jiminhsieh to come back with fixes but given we're near a release, it is just a fast-track alternative.
Akara Sucharitakul
@akara
Sorry if I was not clear @jiminhsieh. This is not an attempt to override your PR but in case we cannot wait to release. Otherwise please continue your PR.
And ignore this one.
And it does contain all your contributions.
Akara Sucharitakul
@akara
@sebady @anilgursel Kindly consider paypal/squbs#716 for the current release. Thanks!
Anil Gursel
@anilgursel
I had minor comments about it which I cannot see anymore. I approved it.
Akara Sucharitakul
@akara
Hmm, did not see those. But this is a different PR that did not include Jimin's changes, since he fixed his PR that night. This is just the conversion changes. Much smaller scope.
Thanks!
Sherif Ebady
@sebady
I just merged this.
Anil Gursel
@anilgursel
thanks @sebady !
Akara Sucharitakul
@akara
Thanks a ton!
ganeshjanu
@ganeshjanu
@akara In my squbs project, have configured a HTTP service . which will accept requests and sends to an Actor and echo it back. A simple POC. When i startup the service, the cpu (2-core) went to 90% and then back to normal. When we send 10/15 parallel request to the service, it will again go back more than 90%. May i know the reason plz?
My config as below:
http {
server {
idle-timeout = 310s
request-timeout = 55s
}
client {
idle-timeout = 500s
}
host-connection-pool {
max-connections = 100
min-connections = 0
max-retries = 0
idle-timeout = infinite
pool-implementation = new
max-open-requests = 128
}
}
I haven't override the default dispatcher & default blocking dispatcher
Anil Gursel
@anilgursel
do you have sample code? Also, you have host-connection-pool but does your POC have outgoing http cal?
Akara Sucharitakul
@akara
@ganeshjanu I can't tell why it went up there since I don't know the facilities used by your code. But you can use a profiler like JMC to find out what is taking your CPU.
Sherif Ebady
@sebady
@akara The travis builds for 0.12.0 have finished successfully. Can you promote the artificats to Maven central?
Akara Sucharitakul
@akara
If I remember how to do that.
Can you check with @Harikiranvuyyuru real quick whether he has the process? If not I'll have to figure it out.
Sherif Ebady
@sebady
I will reach out to him. Thanks
Jimin Hsieh
@jiminhsieh

since @jiminhsieh may be busy

@akara As your guess, I am quite busy recently. 🙁 I don’t have much time to investigate the rest. Anyway, thanks for the cleaning up the rest at paypal/squbs#716. :)

Akara Sucharitakul
@akara
Thanks @jiminhsieh ! Really appreciate your help.
Alpesh Patel
@alpeshrpatel
Hi Guys
Anil Gursel
@anilgursel
Hi
Alpesh Patel
@alpeshrpatel
I am very new to squbs. Please let me know if anybody have done POC for kafka --> squbs and squbs--> kafka
Anil Gursel
@anilgursel
yes, we have quite a few use cases that uses Kafka. We use Alpakka Kafka Connector https://doc.akka.io/docs/akka-stream-kafka/current/ along with Perpetual Stream https://squbs.readthedocs.io/en/latest/perpetualstream/
Alpesh Patel
@alpeshrpatel
@anilgursel There is no clear example or library with perpetualstream..can you please guide me
I am getting confuse between akka and scubs ..Do you have any archive which i can refer
Anil Gursel
@anilgursel
squbs is built on Akka. What Perpetual Stream provides is a way to hook into squbs application startup/shutdown lifecycle. For instance, one may not prefer to start consuming from Kafka until rest of the application is up and ready.. or to gracefully shutdown the stream when the app is shutting down. PerpetualStream integrates with lifecycle events automatically and starts/shutsdown the stream based on those.
I would suggest reading the doc. Other than that, I do not thnk there is an example code of it.
Alpesh Patel
@alpeshrpatel
@anilgursel ..I tried to use the example but i don't see any config for kafka or messaging queue
Anil Gursel
@anilgursel
Because PerpetualStream is not specific to Kafka. For Kafka specific configuration please see Alpakka documentation.
Jason Carreira
@jasoncarreira
Has anyone looked at integrating Akka Typed with Squbs?
Anil Gursel
@anilgursel
Unfortunately, not yet.