v0.0.7

What's Changed

• Update go v1.22 and confluent-kafka-go v2.3.0 (#16) by @ldechoux in #18

Full Changelog: v0.0.5...v0.0.7

instrumentation/otel/v0.0.7

What's Changed

• Update go v1.22 and confluent-kafka-go v2.3.0 (#16) by @ldechoux in #18

Full Changelog: instrumentation/otel/v0.0.5...instrumentation/otel/v0.0.7

v0.0.5

What's Changed

• Added OpenTelemetry collector instrumentation by @eko in #12

New Contributors

• @eko made their first contribution in #12

Full Changelog: v0.0.4...v0.0.5

v0.0.4

What's Changed

• Update confluent-kafka-go dependency to v1.5.2 by @iotafr in #8
• Fix integration test by @iotafr in #9
• Fix worker instrumentation by @fkarakas in #13
• multi collector by @fkarakas in #14

Full Changelog: v0.0.3...v0.0.4

instrumentation/otel/v0.0.5

What's Changed

• Added OpenTelemetry collector instrumentation by @eko in #12

New Contributors

• @eko made their first contribution in #12

Full Changelog: v0.0.4...instrumentation/otel/v0.0.5

v0.0.3

• Added MultiCollector

Release v0.0.2

Migrate to go 1.15 and confluent-kafka-go v1.5.2

Initial release (for internal use)

Allow instrumentation with a collector interface (#5)

* Allow instrumentation with a collector interface

Add the Collector interface which will allow the instrumentation of the kafka trasnformer actions:
consume, transform, produce/project

The Before and After functions will be called before and after each main "actions" made by the transformer.

Also add one example, fix the README.

* Update README.md

Co-Authored-By: Vincent Composieux <vincent@composieux.fr>

* Apply suggestions from code review

Co-Authored-By: Vincent Composieux <vincent@composieux.fr>

* Reviews commit

* Add workerTimeout

* Fix nil panic on collector

Co-authored-by: Vincent Composieux <vincent@composieux.fr>