Thanks!
And by the way, in the migration guide it doesn't mention that the Routing
result type has gone from Unit to Future[RouteResult]. I think it'd help a
lot of people if you'd mention it and even add a reference to the article
written by Johan. It really helped a lot :)
On Tuesday, Decembe
The answer lies in UnstartedCell, but beware that this code may be morally
challenging: it uses a Lock ;-)
Regards, Roland
Sent from my iPhone
> On 21 Dec 2016, at 08:02, stella wrote:
>
> I'm trying to understand how actor creating is being performed internally.
> So, once we created our A
On Tue, Dec 20, 2016 at 11:34 PM, Anil Gursel wrote:
> I see that unzip does not pull the next element when fusing is on. I
> understand that when fusing is on, a message goes through the entire stream
> and then the next message goes through.
>
This is not true, messages are handled concurrent
I think what is happening here is that zip does not pull until the delayed
element has come out, meaning that the second (less delayed) element will not
overtake it. mapAsync is effectively a buffer, so you'll need a buffer in front
of zip.in0 as well to enable parallelism.
Regards, Roland
Se
Yes, that might be the case.
On Wed, Dec 21, 2016 at 9:39 AM, Roland Kuhn wrote:
> I think what is happening here is that zip does not pull until the delayed
> element has come out, meaning that the second (less delayed) element will
> not overtake it. mapAsync is effectively a buffer, so you'll
Good idea, thanks - I made it a ticket.
https://github.com/akka/akka-http/issues/675
If you had some minutes to spare it'd be awesome if you could help us out
by writing what you think would be useful here:
https://github.com/akka/akka-http/edit/master/docs/src/main/paradox/scala/http/migration-gu
I have found tcp ssl support in akka 2.2 but didn't found how to appy ssl
support in current stable version. Can anyone help to know how to apply ssl
support like
this
https://github.com/akka/akka/blob/v2.2.0/akka-docs/rst/java/code/docs/io/japi/SslDocTest.java
--
>> Read the doc
Done! :)
Again, thanks a lot!
On Wednesday, December 21, 2016 at 2:30:11 PM UTC+2, Konrad Malawski wrote:
>
> Good idea, thanks - I made it a ticket.
> https://github.com/akka/akka-http/issues/675
>
> If you had some minutes to spare it'd be awesome if you could help us out
> by writing what you
You should take a look at Akka Streams. You can combine
akka.streams.javadsl.Tcp and akka.streams.javadsl.TLS to create custom
SSL/TLS enabled TCP servers and clients.
Cheers,
Rafał
W dniu środa, 21 grudnia 2016 13:59:27 UTC+1 użytkownik Gaurav Kumar
Jayswal napisał:
>
> I have found tcp ssl s
I have this stream:
Source(IndexedSeq(ByteString.empty))
.via(
Tcp().outgoingConnection(bsAddress, bsPort)
.via(Framing.delimiter(ByteString("\n"), 256, allowTruncation = true))
.map(_.utf8String)
)
.map(m => new ProducerRecord[Array[Byte], String](kafkaTopic, m))
.runWith(
Producer.pl
Thanks for the update. Yes, it should be done at startup.
On Wed, Dec 21, 2016 at 9:36 PM, Víctor Martínez
wrote:
> Hi,
>
>
>
> Finally, I have the solution. When the sharding is created in the request
> the sharding fail. If I start the cluster in main all work right.
>
>
>
> Thanks Patrick for
Thanks Endre and Roland! Yes, when I add a buffer just before zip.in0,
both tests pass:
unzip.out0.buffer(10, OverflowStrategy.backpressure) ~> zip.in0
So, adding the buffer is enabling the parallelism. However, why does not
the first test (the one without zip/unzip) need a buffer to enable
pa
.zip synchronizes its input streams because it requires one element from each
for every output, .merge consumes its inputs independently (as long as there is
downstream demand).
Regards,
Roland
> 21 dec. 2016 kl. 22:20 skrev Anil Gursel :
>
> Thanks Endre and Roland! Yes, when I add a buffer
For anyone who wants to do something similar here is how i have done with
akka-http 10.
DebuggingDirectives.logRequestResult(LoggingMagnet(_ => clockHTTPTime(log)))
private def clockHTTPTime(log: LoggingAdapter)(req: HttpRequest): (Any) => Unit
= {
def clockHTTPTimeInternal(log: LoggingAdapte
Hi,
I am using Akka Kafka stream
(http://doc.akka.io/docs/akka-stream-kafka/current/home.html) to stream
messages from Kafka, if Kafka server is down, I starting getting following
error:
Consumer interrupted with WakeupException after timeout. Message: null.
Current value of akka.kafka.consum
so far I could able be think create KafkaConsumerActor in Supervisor with
supervisor strategy and use same with Consumer.committableExternalSource
val consumer: ActorRef =
context.actorOf(KafkaConsumerActor.props(consumerSettings))
Thanks
Arun
On Thursday, December 22, 2016 at 10:59:12 AM UTC
16 matches
Mail list logo
