Aiven-Open / Aiven-Open/opensearch-connector-for-apache-kafka
Retry on conflict should have its own config
- Ngôn ngữ chính
- Java
- Star
- 95
- Fork
- 61
- Merge trung bình
- 11 giờ 52 phút
- Pull request đã merge (30 ngày)
- 7
Mô tả
Hi, currently retry on conflict value is coupled to max.inflight.request, meaning that if we set max.inflight.request to 1, then the retry on conflict value will be 1. And it is capped at 3. Is there any reasoning why retry on conflict doesn't have their own config instead of coupling it with the inflight request and capped it to 3 ?
```
if (config.indexWriteMethod() == IndexWriteMethod.UPSERT) {
bulkOperation = BulkOperation.of(b -> b.update(u -> u.id(documentId)
.index(indexName)
.routing(routing)
.document(binaryData)
.upsert(binaryData)
.docAsUpsert(true)
.retryOnConflict(Math.min(config.maxInFlightRequests(), 3))));
```
I can help to make a PR if this is not intended.
Thank you
Hướng dẫn đóng góp
Hướng nghiên cứu
Start at the UPSERT branch shown in the issue, then trace how max.inflight.request is defined and passed through the connector configuration. Done means retryOnConflict is controlled by its own configuration rather than Math.min(config.maxInFlightRequests(), 3), with the resulting behavior covered by the relevant project tests.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Đánh giá
- Công nghệ
- java, kafka
- Lĩnh vực
- backend, distributed-systems, search
- Loại issue
- Tính năng
- Độ khó
- 3/5
- Thời gian dự kiến
- 1-2 ngày
- Mức độ hoạt động
- Ít trao đổi
- Độ rõ ràng
- Khá rõ ràng
- Mức phù hợp với người mới
- 62/100