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
Ordering
- Alphabetic
- By Inheritance
Inherited
- KafkaConfig
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- 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
- val avroAsJsonSerialization: Option[Boolean]
- val avroKryoGenericRecordSchemaIdSerialization: Option[Boolean]
- val consumerGroupNamingStrategy: Option[ConsumerGroupNamingStrategy.Value]
- def defaultMaxOutOfOrdernessMillis: Option[Long]
- def forceLatestRead: Option[Boolean]
- val kafkaAddress: String
- val kafkaEspProperties: Option[Map[String, String]]
- val kafkaProperties: Option[Map[String, String]]
- val schemaRegistryCacheConfig: SchemaRegistryCacheConfig
- def schemaRegistryClientKafkaConfig: SchemaRegistryClientKafkaConfig
- val topicsExistenceValidationConfig: TopicsExistenceValidationConfig
- val useStringForKey: Boolean