evolution-gaming / skafka / 14111203086
77%

DEFAULT BRANCH: master
Ran
Jobs 3
Files 58
Run time 1min
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
coverage: 92.547% (-2.0%) from 94.527%
14111203086

push

web-flow 
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

0 of 1 new or added line in 1 file covered. (0.0%)

1119 existing lines in 43 files now uncovered.

2558 of 2764 relevant lines covered (92.55%)

1.77 hits per line

New Missed Lines in Diff

Lines Coverage ∆ File
1
43.38
 -54.39% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/Consumer.scala

Uncovered Existing Lines

Lines Coverage ∆ File
1
0.0
 -100.0% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/AutoOffsetReset.scala
1
66.67
 -33.33% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/IsolationLevel.scala
1
66.67
 -33.33% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/WithSize.scala
1
60.0
 -20.0% skafka/src/main/scala/com/evolutiongaming/skafka/SecurityProtocol.scala
2
0.0
 0.0% modules/play-json/src/main/scala/com/evolutiongaming/skafka/producer/ToBytesFromWrites.scala
2
25.0
 -16.67% skafka/src/main/scala/com/evolutiongaming/skafka/ClientMetricsProvider.scala
2
81.82
 -18.18% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerRecords.scala
2
50.0
 -50.0% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/RebalanceListener1.scala
2
33.33
 -46.67% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/RebalanceListener.scala
2
66.67
 -33.33% skafka/src/main/scala/com/evolutiongaming/skafka/producer/RecordMetadata.scala
3
50.0
 -50.0% modules/play-json/src/main/scala/com/evolutiongaming/skafka/producer/JsonProducer.scala
3
57.14
 -42.86% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerOf.scala
3
72.73
 -27.27% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerRecord.scala
3
66.67
 -33.33% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/RebalanceConsumer.scala
3
50.0
 -50.0% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/SerialListeners.scala
3
33.33
 -36.67% skafka/src/main/scala/com/evolutiongaming/skafka/KeystoreType.scala
3
83.33
 -16.67% skafka/src/main/scala/com/evolutiongaming/skafka/MetricsConfig.scala
3
40.0
 -60.0% skafka/src/main/scala/com/evolutiongaming/skafka/PartitionInfo.scala
4
20.0
 -80.0% skafka/src/main/scala/com/evolutiongaming/skafka/ClientDnsLookup.scala
4
42.86
 -57.14% skafka/src/main/scala/com/evolutiongaming/skafka/producer/Acks.scala
4
20.0
 -80.0% skafka/src/main/scala/com/evolutiongaming/skafka/producer/CompressionType.scala
6
40.0
 -60.0% skafka/src/main/scala/com/evolutiongaming/skafka/FromBytes.scala
6
62.5
 -37.5% skafka/src/main/scala/com/evolutiongaming/skafka/Offset.scala
6
64.71
 -31.29% skafka/src/main/scala/com/evolutiongaming/skafka/Partition.scala
7
74.19
 -23.03% skafka/src/main/scala/com/evolutiongaming/skafka/ConfigHelpers.scala
7
66.67
 -27.08% skafka/src/main/scala/com/evolutiongaming/skafka/JaasConfig.scala
7
81.08
 -18.92% skafka/src/main/scala/com/evolutiongaming/skafka/producer/ProducerConverters.scala
7
30.0
 -70.0% skafka/src/main/scala/com/evolutiongaming/skafka/producer/ProducerOf.scala
11
0.0
 0.0% modules/metrics/src/main/scala/com/evolutiongaming/skafka/producer/ProducerMetricsOf.scala
12
79.41
 -18.18% skafka/src/main/scala/com/evolutiongaming/skafka/CommonConfig.scala
15
0.0
 0.0% modules/metrics/src/main/scala/com/evolutiongaming/skafka/metrics/KafkaMetricsRegistry.scala
15
90.24
 -9.3% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/RebalanceCallback.scala
17
80.0
 -20.0% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConfig.scala
18
81.44
 -18.56% skafka/src/main/scala/com/evolutiongaming/skafka/Converters.scala
24
76.0
 -24.0% skafka/src/main/scala/com/evolutiongaming/skafka/producer/ProducerConfig.scala
25
0.0
 0.0% modules/metrics/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetricsOf.scala
27
0.0
 0.0% modules/metrics/src/main/scala/com/evolutiongaming/skafka/metrics/KafkaMetricsCollector.scala
29
68.48
 -31.52% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerConverters.scala
52
38.03
 -35.5% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/ConsumerMetrics.scala
57
36.36
 -55.42% skafka/src/main/scala/com/evolutiongaming/skafka/KafkaHealthCheck.scala
65
36.84
 -45.89% skafka/src/main/scala/com/evolutiongaming/skafka/producer/ProducerMetrics.scala
132
46.34
 -53.66% skafka/src/main/scala/com/evolutiongaming/skafka/producer/Producer.scala
522
43.38
 -54.39% skafka/src/main/scala/com/evolutiongaming/skafka/consumer/Consumer.scala
Jobs
ID Job ID Ran Files Coverage
1 Scala 3.3.1 - 14111203086.1 58
52.69
2 Scala 2.13.12 - 14111203086.2 58
69.88
3 Scala 2.12.18 - 14111203086.3 58
68.07
Source Files on build 14111203086