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

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. KafkaConfig
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new 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)

Value Members

  1. val avroAsJsonSerialization: Option[Boolean]
  2. val avroKryoGenericRecordSchemaIdSerialization: Option[Boolean]
  3. val consumerGroupNamingStrategy: Option[ConsumerGroupNamingStrategy.Value]
  4. def defaultMaxOutOfOrdernessMillis: Option[Long]
  5. def forceLatestRead: Option[Boolean]
  6. val kafkaAddress: String
  7. val kafkaEspProperties: Option[Map[String, String]]
  8. val kafkaProperties: Option[Map[String, String]]
  9. val schemaRegistryCacheConfig: SchemaRegistryCacheConfig
  10. def schemaRegistryClientKafkaConfig: SchemaRegistryClientKafkaConfig
  11. val topicsExistenceValidationConfig: TopicsExistenceValidationConfig
  12. val useStringForKey: Boolean