[KAFKA-212] Closing cursor exception Created: 26/Mar/21 Updated: 28/Oct/23 Resolved: 29/Mar/21 |
|
| Status: | Closed |
| Project: | Kafka Connector |
| Component/s: | Source |
| Affects Version/s: | None |
| Fix Version/s: | 1.5.0 |
| Type: | Bug | Priority: | Major - P3 |
| Reporter: | Andrey B | Assignee: | Ross Lawley |
| Resolution: | Fixed | Votes: | 0 |
| Labels: | None | ||
| Remaining Estimate: | Not Specified | ||
| Time Spent: | Not Specified | ||
| Original Estimate: | Not Specified | ||
| Issue Links: |
|
||||||||
| Description |
|
Hi
As I understand exception happened because the task tried to close a cursor that already has been closed. This happened on the 1.3.0 version, but I see that this part of the code in the master wasn't changed since 1.3.0. |
| Comments |
| Comment by Andrey B [ 29/Mar/21 ] | ||||||||||||||||||
|
Hi, Ross! When do you planning to make the next release? | ||||||||||||||||||
| Comment by Githook User [ 29/Mar/21 ] | ||||||||||||||||||
|
Author: {'name': 'Ross Lawley', 'email': 'ross.lawley@gmail.com', 'username': 'rozza'}Message: Ensure closing the change stream cursor doesn't leak any errors.
| ||||||||||||||||||
| Comment by Ross Lawley [ 29/Mar/21 ] | ||||||||||||||||||
|
Thanks for the ticket, this looks to be an issue of the Java driver itself, it should be more resilient to replicaset changes. That said we can handle an exception better when trying to close the cursor in the connector, so it can close the cursor and then retry to create a new one to match the read preference. Ross | ||||||||||||||||||
| Comment by Andrey B [ 26/Mar/21 ] | ||||||||||||||||||
|
The ticket description not quite correct, but I can't edit it. The secondary was hidden not killed. The problem reproduced on master.
I used this env to test https://github.com/mongodb/mongo-kafka/tree/master/docker steps to reproduce:
Note: I just not sure what replica using by the connector, so hide both of them. |