-
Notifications
You must be signed in to change notification settings - Fork 18
update Kafka client to 4.0.0 #484
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
base: master
Are you sure you want to change the base?
Conversation
…setAndMetadata], consumerGroupId: String)`
| for { | ||
| _ <- actions.add(Action.PartitionsAssignedEnter) | ||
| _ <- assigned0.complete(()) | ||
| _ <- assigned1.get |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
removed as it creates dead-lock (1)
|
|
||
| _ <- assigned0.get.toResource | ||
| _ <- consumer.topics.toResource | ||
| _ <- assigned1.complete(()).toResource |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
removed as it creates dead-lock (2)
| Action.Topics, | ||
| Action.PollExit |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this part exhibits race condition - sometimes these 2 actions are swapped
| lost0 <- Deferred[F, Unit].toResource | ||
| lost1 <- Deferred[F, Unit].toResource | ||
| listener = new RebalanceListener[F] { | ||
| listener = new RebalanceListener1WithConsumer[F] { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I am not sure, if this is the correct way how to migrate this unit-test
| Action.PartitionsLostEnter, | ||
| Action.Topics, | ||
| Action.PartitionsLostExit, | ||
| Action.Topics, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
do we know why this has changed? this order seems weird to me
| compressionType = CompressionType.Lz4, | ||
| retries = 8, | ||
| maxInFlightRequestsPerConnection = 7, | ||
| partitionerClass = Some(classOf[DefaultPartitioner]), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
is this something related to changes in java kafka-clients model? I tried to find the corresponding change to ProducerConfig in this changeset but I couldn't
kafka-clientsto v4.0.0RebalanceListener