Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
Anil Gursel
@anilgursel
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.
Jason Carreira
@jasoncarreira
Any comparisons of Squbs to Lagom?
Anil Gursel
@anilgursel
there is no doc that compares the feature sets, I do not know if it is something that can directly be compared though. squbs tries to stick to Akka and Akka HTTP API.
Jason Carreira
@jasoncarreira
Okay, thanks. Going through the docs trying to understand the feature set
Jason Carreira
@jasoncarreira
I see that akka-contrib and Aggregator has been deprecated as of Akka 2.5 ( https://doc.akka.io/docs/akka/2.5.3/scala/project/migration-guide-2.4.x-2.5.x.html )
Aggregator is the basis of the Orchestrator DSL, so what's the plan there?
Anil Gursel
@anilgursel
If I am not wrong, aggregator was contributed to Akka by @akara (he is the creator of squbs). So, when aggregator becomes unavailable from Akka, we can pull it in to squbs. Haven’t decided on a plan on that yet.
jacobg
@jacobg
It seems that when the circuit breaker is open, it just bypasses the wrapped flow, pushes a failure downstream, and pulls the next element. That is, there is no backpressure when the circuit is open. Am I understanding that correctly? And if so, why wouldn’t we to apply backpressure until the circuit closes?
sakshi ganeriwal
@sakshiganeriwal
@akara @anilgursel is there some way in which i can restart my squbs app through a config?
Like we have a use case where if we add a new topic to the config file we want to restart the app. So, is there a way in which i can configure an auto app restart??
Akara Sucharitakul
@akara
@sakshiganeriwal I'd say no, especially in your circumstances. Allowing a config to trigger a restart can be a dangerous feature. It is better if the config just has the metadata saying restart required. It also allows you to change multiple configs and restart. So I'd keep these separate actions.
Anil Gursel
@anilgursel
@jacobg The last section of https://squbs.readthedocs.io/en/latest/circuitbreaker/ talks about it little bit. Depending on the use case, it may not always be the best option to back pressure. What if a an alternate service calls is used when the circuit is open for instance.
Mudit Sinha
@muditsin
Would it be a good feature to add an OrderedCircuitBreaker? Currently the documentation says the CircuitBreaker might potentially change the order of messages.
Anil Gursel
@anilgursel
you can take a look at https://squbs.readthedocs.io/en/latest/flow-ordering/ and potentially combine the two or create a new stage that does both.. the important thing to keep in mind is what happens when elements come out-of-order and a specific element is dropped etc.