New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
contrib/segmentio/kafka-go: add implementation add tracing for kafka writer and kafka reader #1152
Commits on Apr 9, 2021
-
Add tracing for segmentio/kafka-go
Pradeep Palanisamy committedApr 9, 2021 -
Update import as per guidelines
Pradeep Palanisamy committedApr 9, 2021
Commits on Apr 11, 2021
-
Update circleci config to add topic and use new topic in test
Pradeep Palanisamy committedApr 11, 2021 -
Use the same topic with last offset
Pradeep Palanisamy committedApr 11, 2021 -
Pradeep Palanisamy committed
Apr 11, 2021 -
Use apache kafka image to test segmentio kafka-go changes
Pradeep Palanisamy committedApr 11, 2021
Commits on Apr 12, 2021
-
Update apache kafka configuration to expose different port
Pradeep Palanisamy committedApr 12, 2021 -
Fix
Socket server failed to bind to kafka:9092: Unresolved address
……error
Pradeep Palanisamy committedApr 12, 2021 -
Use container name to fx port conflict issue
Pradeep Palanisamy committedApr 12, 2021 -
Pradeep Palanisamy committed
Apr 12, 2021 -
Use kafka listener and advertised listener to fix connection issue
Pradeep Palanisamy committedApr 12, 2021 -
Add asserts to validate consumer span
Pradeep Palanisamy committedApr 12, 2021
Commits on Apr 13, 2021
-
Move Extract function to headers.go file
Pradeep Palanisamy committedApr 13, 2021
Commits on Apr 21, 2021
-
Use same container for confluentinc kafka and segmentio kafka client
Pradeep Palanisamy committedApr 21, 2021
Commits on Jan 28, 2022
-
drop NewMessageCarrier function, just use MessageCarrier{msg}
-
-
Commits on Feb 11, 2022
Commits on Feb 14, 2022
-
create kafka topic for segmentio
This library fails on brand new topics as the leader is elected, to get around this create the topic in setup.