Type Members

1.  case class CachedTopicsExistenceValidatorConfig(autoCreateFlagFetchCacheTtl: FiniteDuration, topicsFetchCacheTtl: FiniteDuration, adminClientTimeout: FiniteDuration) extends Product with Serializable
2.  case class DefaultProducerCreator[K, V](kafkaConfig: KafkaConfig) extends KafkaProducerCreator[K, V] with Product with Serializable
3.  case class KafkaConfig(kafkaAddress: String, kafkaProperties: Option[Map[String, String]], kafkaEspProperties: Option[Map[String, String]], consumerGroupNamingStrategy: Option[ConsumerGroupNamingStrategy.Value] = None, avroKryoGenericRecordSchemaIdSerialization: Option[Boolean] = None, topicsExistenceValidationConfig: TopicsExistenceValidationConfig = ..., useStringForKey: Boolean = true, schemaRegistryCacheConfig: SchemaRegistryCacheConfig = SchemaRegistryCacheConfig(), avroAsJsonSerialization: Option[Boolean] = None) extends Product with Serializable
4.  trait KafkaProducerCreator[K, V] extends AnyRef
5.  trait KafkaUtils extends LazyLogging
6.  case class MockProducerCreator[K, V](mockProducer: MockProducer[K, V]) extends KafkaProducerCreator[K, V] with Product with Serializable
7.  case class PreparedKafkaTopic(original: String, prepared: String) extends Product with Serializable
8.  case class SchemaRegistryCacheConfig(availableSchemasExpirationTime: Option[FiniteDuration] = Some(10.seconds), parsedSchemaAccessExpirationTime: Option[FiniteDuration] = Some(120.minutes), maximumSize: Long = CacheConfig.defaultMaximumSize) extends Product with Serializable
9.  case class SchemaRegistryClientKafkaConfig(kafkaProperties: Map[String, String], cacheConfig: SchemaRegistryCacheConfig, avroAsJsonSerialization: Option[Boolean]) extends Product with Serializable
10.  case class TopicsExistenceValidationConfig(enabled: Boolean, validatorConfig: CachedTopicsExistenceValidatorConfig = ...) extends Product with Serializable