Skip to content

Unsafe access to Kafka consumer in seek operation #3108

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

Closed
sobychacko opened this issue Mar 8, 2024 · 0 comments · Fixed by #3109
Closed

Unsafe access to Kafka consumer in seek operation #3108

sobychacko opened this issue Mar 8, 2024 · 0 comments · Fixed by #3109
Assignees
Milestone

Comments

@sobychacko
Copy link
Contributor

When the seek API that uses the user-provided function to compute the offset to seek, there is a concurrency issue in which the Kafka consumer is used unsafely. See this for more details.

@sobychacko sobychacko self-assigned this Mar 8, 2024
@sobychacko sobychacko added this to the 3.2.0-M2 milestone Mar 8, 2024
sobychacko added a commit to sobychacko/spring-kafka that referenced this issue Mar 8, 2024
Fixes: spring-projects#3108

* When the seek API that uses the user-provided function to compute the offset to seek,
  there is a concurrency issue in which the Kafka consumer is used unsafely.

See this for details: spring-projects#3078 (comment)
artembilan pushed a commit that referenced this issue Mar 8, 2024
Fixes: #3108

* When the seek API that uses the user-provided function to compute the offset to seek,
  there is a concurrency issue in which the Kafka consumer is used unsafely.

See this for details: #3078 (comment)

* Fix Checkstyle violation
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant