Package org.apache.solr.crossdc.manager.consumer

Class PartitionManager

java.lang.Object

org.apache.solr.crossdc.manager.consumer.PartitionManager

public class PartitionManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PartitionManager.PartitionWork
static class	PartitionManager.WorkUnit

Method Summary

Modifier and Type	Method	Description
void	checkOffsetsAndUpdate()
PartitionManager.PartitionWork	getPartitionWork(org.apache.kafka.common.TopicPartition partition)

Methods inherited from class java.lang.Object

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

Method Details

getPartitionWork

public PartitionManager.PartitionWork getPartitionWork(org.apache.kafka.common.TopicPartition partition)

checkOffsetsAndUpdate

public void checkOffsetsAndUpdate()
                           throws Throwable

Throws:

Throwable