Skip to content

Commit

Permalink
* Upgrade dependencies
Browse files Browse the repository at this point in the history
* Fix deprecation in the `ConsumerHandler` for `eventScheduler.start()`
* Use generated `producerId` and `receiverId` if `CLIENT_ID_CONFIG` is not provided
* Use an `Observation` in the `DefaultKafkaReceiver` to add a `CONSUMER` span to
the trace provided by the `PRODUCER` in the record.
* Recommend to use a `KafkaReceiverObservation.RECEIVER_OBSERVATION` API directly
in the target end-user code when need to have an observation context around record handling
  • Loading branch information
artembilan committed Sep 6, 2023
1 parent d971377 commit 557449d
Show file tree
Hide file tree
Showing 16 changed files with 884 additions and 738 deletions.
7 changes: 3 additions & 4 deletions gradle/libs.versions.toml
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,10 @@ reactorCore = "3.4.33-SNAPSHOT"
asciidoctor = "3.3.2"
kafka-doc = "28"
log4j = "2.17.1"
micrometer = "1.10.4"
micrometer = "1.10.10"
powermock = "2.0.9"
reactiveStreams = "1.0.3"
micrometer = "1.11.0-M1"
micrometerTracing = '1.1.0-M1'
micrometerTracing = '1.1.4'

[libraries]
kafka = "org.apache.kafka:kafka-clients:2.8.2"
Expand All @@ -30,7 +29,7 @@ powermock-core = { module = "org.powermock:powermock-core", version.ref = "power
powermock-junit = { module = "org.powermock:powermock-module-junit4", version.ref = "powermock" }
powermock-mockito = { module = "org.powermock:powermock-api-mockito2", version.ref = "powermock" }
slf4j = "org.slf4j:slf4j-api:1.7.36"
testcontainers = "org.testcontainers:kafka:1.16.3"
testcontainers = "org.testcontainers:kafka:1.19.0"
micrometer-observation = { module = "io.micrometer:micrometer-observation", version.ref = "micrometer" }
micrometer-tracing-test = { module = "io.micrometer:micrometer-tracing-integration-test", version.ref = "micrometerTracing" }

Expand Down
Loading

0 comments on commit 557449d

Please sign in to comment.