Package org.apache.solr.crossdc.common
Class KafkaMirroringSink
java.lang.Object
org.apache.solr.crossdc.common.KafkaMirroringSink
- All Implemented Interfaces:
Closeable,AutoCloseable,RequestMirroringSink
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()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)
-
Constructor Details
-
KafkaMirroringSink
-
-
Method Details
-
submit
Description copied from interface:RequestMirroringSinkSubmits 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- Specified by:
submitin interfaceRequestMirroringSink- Parameters:
request- the request that is to be mirrored- Throws:
MirroringException- Implementations may throw an exception
-
submitToDlq
- Specified by:
submitToDlqin interfaceRequestMirroringSink- Throws:
MirroringException
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-