cluster

Type Members

1. class BrokerViewCacheActor extends BaseActor with LongRunningPoolActor with BaseClusterActor

   

2. case class BrokerViewCacheActorConfig(kafkaStateActorPath: ActorPath, clusterContext: ClusterContext, longRunningPoolConfig: LongRunningPoolConfig, updatePeriod: FiniteDuration = 10 seconds) extends Product with Serializable

   

3. class ClusterManagerActor extends BaseClusterQueryCommandActor with CuratorAwareActor with BaseZkPath

   

4. case class ClusterManagerActorConfig(pinnedDispatcherName: String, baseZkPath: String, curatorConfig: CuratorConfig, clusterConfig: ClusterConfig, consumerProperties: Option[Properties], askTimeoutMillis: Long = 2000, mutexTimeoutMillis: Int = 4000, simpleConsumerSocketTimeoutMillis: Int = 10000) extends Product with Serializable

   

5. case class ConsumerInstanceSubscriptions extends Product with Serializable

   

6. class KafkaAdminClient extends AnyRef

   

7. case class KafkaAdminClientActor(config: KafkaAdminClientActorConfig) extends BaseClusterQueryActor with LongRunningPoolActor with Product with Serializable

   

8. case class KafkaAdminClientActorConfig(clusterContext: ClusterContext, longRunningPoolConfig: LongRunningPoolConfig, kafkaStateActorPath: ActorPath, consumerProperties: Option[Properties]) extends Product with Serializable

   

9. class KafkaCommandActor extends BaseClusterCommandActor with LongRunningPoolActor

   

10. case class KafkaCommandActorConfig(curator: CuratorFramework, longRunningPoolConfig: LongRunningPoolConfig, askTimeoutMillis: Long = 400, clusterContext: ClusterContext, adminUtils: AdminUtils) extends Product with Serializable

    

11. case class KafkaManagedOffsetCache(clusterContext: ClusterContext, adminClient: KafkaAdminClient, consumerProperties: Option[Properties], bootstrapBrokerList: BrokerList, config: KafkaManagedOffsetCacheConfig) extends Runnable with Closeable with Logging with Product with Serializable

    

12. case class KafkaManagedOffsetCacheConfig(groupMemberMetadataCheckMillis: Int = ..., groupTopicPartitionOffsetMaxSize: Int = ..., groupTopicPartitionOffsetExpireDays: Int = ...) extends Product with Serializable

    

13. class KafkaStateActor extends BaseClusterQueryCommandActor with LongRunningPoolActor

    

14. case class KafkaStateActorConfig(curator: CuratorFramework, pinnedDispatcherName: String, clusterContext: ClusterContext, offsetCachePoolConfig: LongRunningPoolConfig, kafkaAdminClientPoolConfig: LongRunningPoolConfig, partitionOffsetCacheTimeoutSecs: Int, simpleConsumerSocketTimeoutMillis: Int, consumerProperties: Option[Properties], kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig) extends Product with Serializable

    

15. trait OffsetCache extends Logging

    

16. case class OffsetCacheActive(curator: CuratorFramework, kafkaAdminClient: KafkaAdminClient, clusterContext: ClusterContext, partitionLeaders: (String) ⇒ Option[List[(Int, Option[BrokerIdentity])]], topicDescriptions: (String, Boolean) ⇒ Option[TopicDescription], cacheTimeoutSecs: Int, socketTimeoutMillis: Int, kafkaVersion: KafkaVersion, consumerProperties: Option[Properties], kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig, getBrokerList: () ⇒ BrokerList)(implicit ec: ExecutionContext, cf: ClusterFeatures) extends OffsetCache with Product with Serializable

    

17. case class OffsetCachePassive(curator: CuratorFramework, kafkaAdminClient: KafkaAdminClient, clusterContext: ClusterContext, partitionLeaders: (String) ⇒ Option[List[(Int, Option[BrokerIdentity])]], topicDescriptions: (String, Boolean) ⇒ Option[TopicDescription], cacheTimeoutSecs: Int, socketTimeoutMillis: Int, kafkaVersion: KafkaVersion, consumerProperties: Option[Properties], kafkaManagedOffsetCacheConfig: KafkaManagedOffsetCacheConfig, getBrokerList: () ⇒ BrokerList)(implicit ec: ExecutionContext, cf: ClusterFeatures) extends OffsetCache with Product with Serializable

    

18. implicit class TryLogErrorHelper[T] extends Logging