Tags: evolution-gaming/skafka
Tags
Fix ConcurrentModificationException on commitLater (#476) Invocations of consumer.commitAsync should be protected under the consumer semaphore, or you get errors like this when trying to call commitLater concurrently with poll: java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access
Add histogram-based metrics (#440) * Extract ProducerMetrics implementations into named classes * Add Histograms implementation for ProducerMetrics * Extract MapK into a named class * Extract ConsumerMetrics implementations into named classes * Add Histogram implementation of ConsumerMetrics * Name Throwables in MonadCancel * Docs for latencyBuckets * Apply suggestions from code review Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com> * Update skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetrics.scala Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com> * changed name * fix scala 3 * Apply suggestions from code review Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com> * bump minor version --------- Co-authored-by: Mareks Rampāns <8796159+mr-git@users.noreply.github.com> Co-authored-by: Denys Fakhritdinov <denys.fakhritdinov@gmail.com>
PreviousNext