BulkItemCallBack

Use this to deal with item responses and failures; or bulk request errors. By default, the callback is null.

Functions

Link copied to clipboard
abstract fun bulkRequestFailed(e: Exception, ops: List<Pair<String, String?>>)

Called when elasticsearch responds with an error. By default, this is considered fatal and the bulk session closes and is no longer usable and an exception will be thrown. You may choose to keep it open by setting closeOnRequestError to false when you create the BulkSession to e.g. implement a retry strategy or simply drop the failed bulk requests.

Link copied to clipboard
abstract fun itemFailed(operationType: OperationType, item: BulkResponse.ItemDetails)

Called when the bulk response marks the item with a non successful status.

Link copied to clipboard
abstract fun itemOk(operationType: OperationType, item: BulkResponse.ItemDetails)

Called to confirm an item was processes successfully with details about the item (e.g. primary_term, seq_no, id, etc.)