Skip to content
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

[kafka-consumer] Ingester should use topic name from actual Kafka consumer instead of configuration #4593

Merged
merged 2 commits into from
Jul 19, 2023

Conversation

abliqo
Copy link
Contributor

@abliqo abliqo commented Jul 19, 2023

Which problem is this PR solving?

Resolves #4592

Short description of the changes

When handling messages use the topic name from PartitionConsumer that reflects the topic where message is consumed from.

Resolves issue jaegertracing#4592

Summary of changes:
When handling messages use the topic name from PartitionConsumer that reflects the topic where message is consumed from.

Signed-off-by: Alex Bublichenko <[email protected]>
@abliqo abliqo requested a review from a team as a code owner July 19, 2023 15:39
@abliqo abliqo requested a review from joe-elliott July 19, 2023 15:39
Copy link
Member

@yurishkuro yurishkuro left a comment

Choose a reason for hiding this comment

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

please see my question on the ticket

@abliqo abliqo changed the title [kafka-consumer] Support multiple Kafka topics [kafka-consumer] Ingester should use topic name from actual Kafka consumer instead of configuration Jul 19, 2023
@codecov
Copy link

codecov bot commented Jul 19, 2023

Codecov Report

Patch coverage: 100.00% and no project coverage change.

Comparison is base (013ec4d) 97.05% compared to head (7dd4056) 97.05%.

Additional details and impacted files
@@           Coverage Diff           @@
##             main    #4593   +/-   ##
=======================================
  Coverage   97.05%   97.05%           
=======================================
  Files         302      302           
  Lines       17853    17852    -1     
=======================================
  Hits        17327    17327           
+ Misses        422      421    -1     
  Partials      104      104           
Flag Coverage Δ
unittests 97.05% <100.00%> (+<0.01%) ⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files Coverage Δ
cmd/ingester/app/consumer/consumer.go 96.96% <100.00%> (ø)
cmd/ingester/app/consumer/processor_factory.go 100.00% <100.00%> (ø)

... and 1 file with indirect coverage changes

☔ View full report in Codecov by Sentry.
📢 Do you have feedback about the report comment? Let us know in this issue.

@yurishkuro yurishkuro enabled auto-merge (squash) July 19, 2023 19:59
@yurishkuro yurishkuro merged commit 0f3806c into jaegertracing:main Jul 19, 2023
31 checks passed
@abliqo abliqo deleted the multi-kafka-topics branch July 19, 2023 20:19
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.

Ingester should use topic name from actual Kafka consumer instead of configuration
2 participants