Package org.apache.solr.crossdc.common
Interface RequestMirroringSink
-
- All Known Implementing Classes:
KafkaMirroringSink
public interface RequestMirroringSink
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsubmit(MirroredSolrRequest<?> request)Submits a mirrored solr request to the appropriate end-point such that it is eventually received by solr A direct sink may simply use CloudSolrServer to process requests directly.voidsubmitToDlq(MirroredSolrRequest<?> request)
-
-
-
Method Detail
-
submit
void submit(MirroredSolrRequest<?> request) throws MirroringException
Submits a mirrored solr request to the appropriate end-point such that it is eventually received by solr A direct sink may simply use CloudSolrServer to process requests directly. A queueing sink will serialize the request and submit it to a queue for later consumption- Parameters:
request- the request that is to be mirrored- Throws:
MirroringException- Implementations may throw an exception
-
submitToDlq
void submitToDlq(MirroredSolrRequest<?> request) throws MirroringException
- Throws:
MirroringException
-
-