Skip to main content

All Questions

Filter by
Sorted by
Tagged with
0 votes
2 answers
826 views

how can I aggregate the values from an array of micrometer counters

I’m collecting a series of metrics for a kafka stream application, the issue I have is I’d like a consolidated value for the meters of a specific name. To make this a little clearer, these metrics are ...
K Olusanya's user avatar
3 votes
2 answers
3k views

Serde error in Kafka Streams process with Spring Cloud Stream

I´m trying to process some Kafka records using Spring Cloud Stream 3.0.3.RELEASE, but I´m having trouble with Serdes configuration getting an error as soon as a record enters the stream pipeline. ...
vicrerdgz's user avatar
2 votes
1 answer
842 views

Unable to deserialize Avro message using Confluent Schema Registry and Spring Cloud Stream

I am using Spring Cloud Stream and Confluent Schema Registry to register Avro schemas. Schemas are registered successfully. But when my Stream Listener receives a message the payload is still in ...
RSM's user avatar
  • 433
3 votes
2 answers
3k views

Spring Cloud Stream Kafka > consuming Avro messages from Confluent REST Proxy

I have the following scenario: Producer sends Avro encoded messages to Kafka topic via Confluent's REST Proxy (which registers the schema on Confluent's schema registry) as described in http://docs....
neptoon's user avatar
  • 53