Package org.apache.solr.crossdc.common

Class KafkaMirroringSink

java.lang.Object

org.apache.solr.crossdc.common.KafkaMirroringSink

All Implemented Interfaces:

Closeable, AutoCloseable, RequestMirroringSink

public class KafkaMirroringSink
extends Object
implements RequestMirroringSink, Closeable

Constructor Summary

Constructors

Constructor	Description
KafkaMirroringSink(KafkaCrossDcConf conf)

Method Summary

Modifier and Type	Method	Description
void	close()
void	submit(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.
void	submitToDlq(MirroredSolrRequest<?> request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaMirroringSink

public KafkaMirroringSink(KafkaCrossDcConf conf)

Method Details

submit

public void submit(MirroredSolrRequest<?> request)
            throws MirroringException

Description copied from interface: RequestMirroringSink

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

Specified by:

submit in interface RequestMirroringSink

Parameters:

request - the request that is to be mirrored

Throws:

MirroringException - Implementations may throw an exception

submitToDlq

public void submitToDlq(MirroredSolrRequest<?> request)
                 throws MirroringException

Specified by:

submitToDlq in interface RequestMirroringSink

Throws:

MirroringException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException