Type Members

1.  final 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 IdlenessConfig(enabled: Boolean, duration: FiniteDuration = DefaultDuration) extends Product with Serializable
4.  case class KafkaConfig(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, kafkaAddress: Option[String] = None, idleTimeout: Option[IdlenessConfig] = None, sinkDeliveryGuarantee: Option[SinkDeliveryGuarantee.Value] = None) extends Product with Serializable
5.  trait KafkaProducerCreator[K, V] extends AnyRef
6.  trait KafkaUtils extends LazyLogging
7.  case class MockProducerCreator[K, V](mockProducer: MockProducer[K, V]) extends KafkaProducerCreator[K, V] with Product with Serializable
8.  case class PreparedKafkaTopic[T <: TopicName](original: T, prepared: T) extends Product with Serializable
9.  case class SchemaRegistryCacheConfig(availableSchemasExpirationTime: Option[FiniteDuration] = Some(10.seconds), parsedSchemaAccessExpirationTime: Option[FiniteDuration] = Some(120.minutes), maximumSize: Long = CacheConfig.defaultMaximumSize) extends Product with Serializable
10.  case class SchemaRegistryClientKafkaConfig(kafkaProperties: Map[String, String], cacheConfig: SchemaRegistryCacheConfig, avroAsJsonSerialization: Option[Boolean]) extends Product with Serializable
11.  final case class TopicsExistenceValidationConfig(enabled: Boolean, validatorConfig: CachedTopicsExistenceValidatorConfig = ...) extends Product with Serializable
12.  final case class UnspecializedTopicName(name: String) extends Product with Serializable