Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Activity
    Jan Martiska
    @jmartisk
    that's super cool @radcortez !
    Roberto Cortez
    @radcortez
    thanks :)
    Jan Martiska
    @jmartisk
    Just one question pops up in my head - what if someone updates documentation only in one of the project repositories, and nothing in the smallrye.github.io repo? Is there a way to trigger the deploy action without sending a PR?
    To get the changes reflected in the live site
    Roberto Cortez
    @radcortez
    good point, we don’t have that
    I can have a look into it
    Ladislav Thon
    @Ladicek
    I guess re-running the last "deploy website" GitHub action should work
    not friendly, but should
    Roberto Cortez
    @radcortez
    yes that works
    but misleading as well
    Roberto Cortez
    @radcortez
    Here, I added a way to do it now: https://github.com/smallrye/smallrye.github.io/actions?query=workflow%3A%22SmallRye+Website+-+On+Demand%22
    the only downside is that I had to duplicate the jobs code which is a pain
    they don’t support a proper way to compose actions yet
    OleKsimov
    @OleKsimov
    Hello!
    Can anyone help me please with my question from January 10?
    Jan Martiska
    @jmartisk
    @radcortez that's very cool, thanks!! I'll add that into our wiki. Duplicating is bad, but I think we won't need to change the jobs very often, someone just needs to always remember that we need to change both at the same time
    Ladislav Thon
    @Ladicek
    a comment on both places would help with that :-)
    Roberto Cortez
    @radcortez
    GH is working on that, they have some limited support for composed steps for shell scriots but they don’t support actions yet
    so eventually that will go away
    Roberto Cortez
    @radcortez
    @OleKsimov that question is probably for @cescoffier also, if the question is related with Quarkus it might be easier to get a response in Quarkus Zulip: https://quarkusio.zulipchat.com
    André Gonçalves
    @andrerigon
    Hi. I'm using SmallRye Reactive Messaging to consume a kafka topic from Aiven. But I keep getting java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record incompatible with - it seems it cannot deserialize using the schema registry. Producing the value and registering the schema works fine. Any ideas? Thanks!
    39 replies
    miguel-figueiredo
    @miguel-figueiredo

    Hi,
    We’ve detected a memory leak in our service. When getting the references of the objects that are filling the memory, the SmallRye Mutiny classes popped up.
    Can anyone give us some hints on how these references can be released?
    We are using Quarkus 1.10.2.Final with Smallrye Mutiny 0.11.0

    Stack: 

    99% - 9,642,982 instances   9,659,181 instances of java.util.ArrayList
(...)  
  63% - 6,139,063 instances   17,165 instances of com.(...).OurClass$$Lambda$1542
    63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.groups.MultiOnItem$$Lambda$612
      63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.operators.multi.MultiFlatMapOp
        63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.context.ContextPropagationMultiInterceptor$ContextPropagationMulti
          63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.operators.UniCreateFromPublisher
            63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.operators.UniCreateFromPublisher$1
              63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.operators.UniSerializedSubscriber
                63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.context.ContextPropagationUniInterceptor$2
                  63% - 6,139,063 instances   17,165 instances of io.smallrye.mutiny.operators.multi.MultiFlatMapOp$FlatMapMainSubscriber
    43 replies
    Ladislav Thon
    @Ladicek
    pretty sure it's the 6,139,063 instances 17,165 instances of com.(...).OurClass$$Lambda$1542 that you need to let go
    the Mutiny objects will disappear as well
    (if the listing is what I think it is, objects with outgoing references)
    miguel-figueiredo
    @miguel-figueiredo
    These are merged incoming references to the ArrayList.
    Clement Escoffier
    @cescoffier
    do you have a reproducer somwhere?
    I agree with Ladislav, it seems that it keeps reference to the Multi in OurClass$$Lambdas, and you would need to release them.
    miguel-figueiredo
    @miguel-figueiredo
    It's the other way around. The bottom classes keep references to the upper classes. In JProfiler I've requested the merged incoming references.
    Clement Escoffier
    @cescoffier
    I would need a reproducer. Are you consuming the data emitted by the flatten streams?
    1 reply
    David M. Lloyd
    @dmlloyd
    my goodness, the threading functionality of Gitter is just as bad as Slack.
    Ladislav Thon
    @Ladicek
    totally agree, I hate that
    wllianwd
    @wllianwd
    Hello ppl, is anyone working on an implementation of smallrye-messaging for RabbitMQ (amqp 0.9.1)?
    Clement Escoffier
    @cescoffier
    Not that I’m aware of
    We have basic support of RabbitMQ with the AMQP connector, but it requires the AMQP 1.0 plugin in rabbit
    Roman Gluschuk
    @romanFrontEnd

    Hi guys.
    I am trying to configure Jaeger Tracing in my service-mesh.

    In few words our App is : AndroidApp-> Rest API(Quarkus) Service 1 -> Kafka Service 2 -> Kafka Service 3
    On some services we utilize micro profile (Kafka connection approach) on service 3 we utilize Camel (Kafka connection approach).

    I have configured everything according to this tutorial: https://quarkus.io/guides/opentracing.
    And I see separate traces in my locally up jaeger.
    But the main problem for me - how to do them interconnected in scope of one trace.

    So if I call some endpoint Post -> api/{somePath} on service 1 which sends request to service 2 via Kafka
    I want to see all span in scope of one single trace.

    What I have now is Traced Post/Call 1 trace + 1 span and separate Trace to_some_kafka_topis_push + 1 span.

    Any assumptions why ?
    I would be grateful for any help.

    Ken Finnigan
    @kenfinnigan
    @romanFrontEnd You need the Kafka interceptor and inject the trace into the Kafka message going out
    Roman Gluschuk
    @romanFrontEnd
    Thanks, guys. I am using Interceptor approach from a mentioned tutorial. But this doesn't allow me to to make kafka span to be subspan of rest call span of a main trace. Will update when found any solution.
    Obby
    @obbyK
    hallo guys, was updating my quarkus application from version 1.6 to 1.11 and i can see they are changes in the mutiny api, methods like produceUni, on,apply are now deprecated and i can't seem to find the documentation about these changes in one place but thet are some scattered across several issues on github. is there a recommendation page of how to deal with these changes and their effects?
    Clement Escoffier
    @cescoffier
    Their javadoc should indicate the new way. Note that these methods are still working perfectly. While not great (under improvement at least), breaking changes are described on https://github.com/smallrye/smallrye-mutiny/releases
    Obby
    @obbyK
    thanks
    Obby
    @obbyK
    a question here, say you have a method such as public Uni<Response> processRequest(Request request) {...}, if you have a List<Request> requests, how could i combine calling the method on each request so that i possibly return a Multi<Response>?
    Ladislav Thon
    @Ladicek

    something like

    Multi.createFrom().iterable(input)
    .onItem().transformToUni(this::processRequest).concatenate()

    should work I think?

    Clement Escoffier
    @cescoffier
    exactly, use concatenate if you want to preserve the order, otherwise merge (more concurrent, but no ordering). See https://smallrye.io/smallrye-mutiny/getting-started/transforming-items-async#transforming-items-from-multi-the-merge-vs-concatenate-dilemma for details
    Michel Jung
    @micheljung
    Hi guys, I'm trying to use Quarkus to subscribe to a Redis channel. Unfortunately, Quarkus doesn't have any documentation on this but I saw that it uses mutiny under the hood. However, I couldn't find an example for this, either, and I can't make sense of the API
    could anyone provide an example?
    Rafael de Andrade Sousa
    @rafaelsousa
    Hi, is there guidelines concerning code style, like, tabspaces or other stuff like that? Where I work the team uses google code style, but I was wandering if you guys use redhat code style or something like that
    Ladislav Thon
    @Ladicek
    there's https://github.com/smallrye/smallrye-code-rules/blob/master/README.md
    it's automated using the Eclipse formatter Maven plugin
    Rafael de Andrade Sousa
    @rafaelsousa
    Thank you @Ladicek :)
    Obby
    @obbyK
    Hi folks, I have this snippet, i'm wondering how can i throw an error or if there is a better way of approaching the problem?
    .onItem().transformToMulti(items -> items.stream().noneMatch(i -> i.getId().equals(itemToFindId)) ? // how do i thrown an error here? is this recommended? : itemRelatedRepo.findByItemId(itemToFindId) ))
    I tried throwing an error using createFrom.failure() but it complained of type
    Clement Escoffier
    @cescoffier
    Just throw a runtime exception