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!
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
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.
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?
.onItem().transformToMulti(items -> items.stream().noneMatch(i -> i.getId().equals(itemToFindId))
? // how do i thrown an error here? is this recommended?
: itemRelatedRepo.findByItemId(itemToFindId)
))