Skip to content

allow user to disable kafka time in queue tag#1487

Merged
richardstartin merged 2 commits into
masterfrom
richardstartin/disable-kafka-timestamp
May 26, 2020
Merged

allow user to disable kafka time in queue tag#1487
richardstartin merged 2 commits into
masterfrom
richardstartin/disable-kafka-timestamp

Conversation

@richardstartin
Copy link
Copy Markdown
Contributor

Relates to #1448, #1481. Need to be able to avoid calling ConsumerRecord.timestamp when there are old kafka clients present.

@richardstartin richardstartin requested a review from a team as a code owner May 22, 2020 10:22
@tylerbenson
Copy link
Copy Markdown
Contributor

What would you consider an "old" client in this sense? It doesn't make sense to me that this would break things on the clients we currently support.

@richardstartin
Copy link
Copy Markdown
Contributor Author

richardstartin commented May 22, 2020

So the problem is if the timestamp is not LogAppendTime (managed by the broker) and there is a mixed environment of Kafka clients, going back to 0.9. Then there would be no timestamp. Perhaps we should just detect that on ConsumerRecord.timestampType instead.

@richardstartin richardstartin force-pushed the richardstartin/disable-kafka-timestamp branch from 49157c2 to 2a04e73 Compare May 22, 2020 17:55
Copy link
Copy Markdown
Contributor

@bantonsson bantonsson left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Much nicer!

@richardstartin richardstartin merged commit b0f1423 into master May 26, 2020
@richardstartin richardstartin deleted the richardstartin/disable-kafka-timestamp branch May 26, 2020 14:03
@github-actions github-actions Bot added this to the 0.53.0 milestone May 26, 2020
iNikem pushed a commit to open-telemetry/opentelemetry-java-instrumentation that referenced this pull request Jun 2, 2020
* Add time in queue (DataDog/dd-trace-java#1481)

* Minor upgrades (DataDog/dd-trace-java#1495)

* Allow user to disable kafka time in queue tag (DataDog/dd-trace-java#1487)

* Replace Set<Integer> with BitSet for HTTP statuses (DataDog/dd-trace-java#1496)

* Register WeakMapProvider earlier in AgentInstaller (DataDog/dd-trace-java#1480)

* Update codenarc (DataDog/dd-trace-java#1500)

Co-authored-by: Tyler Benson <tyler.benson@datadoghq.com>
Co-authored-by: Nikolay Martynov <mar.kolya@gmail.com>
Co-authored-by: Richard Startin <richard.startin@datadoghq.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants