Skip to content

Commit

Permalink
fix(kafka-ssl-sasl-dsl): (#67)
Browse files Browse the repository at this point in the history
- fixed small issue with DSL
- bumped v2.1.1
  • Loading branch information
Flaxoos authored Nov 11, 2024
1 parent 3448512 commit 4b3ba32
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion gradle.properties
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ github.repository.name=extra-ktor-plugins
kotlin.native.cacheKind.linuxX64=none
kotlin.native.ignoreDisabledTargets=true
gradle.publish.enable.module-metadata=true
version=2.1.0
version=2.1.1
gpr.user=flaxoos
org.gradle.jvmargs=-Xmx2g -XX:MaxMetaspaceSize=2g
kotlin.mpp.applyDefaultHierarchyTemplate=false
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ class KafkaConfig : AbstractKafkaConfig() {
adminPropertiesBuilder
?.build()
?.propertiesContext(this@KafkaConfig)
?.withSslProperties(adminSslPropertiesBuilder)
?.withSslProperties(adminSslPropertiesBuilderPair)
?.withDefaultAdminConfig()
?.delegatingToCommon()
?.kafkaProperties
Expand Down Expand Up @@ -131,14 +131,14 @@ class KafkaConfig : AbstractKafkaConfig() {

// SSL Configurations
internal var commonSslPropertiesBuilderPair: SslPropertiesBuilderPair? = null
internal var adminSslPropertiesBuilder: SslPropertiesBuilder? = null
internal var adminSslPropertiesBuilderPair: SslPropertiesBuilderPair? = null
internal var producerSslPropertiesBuilderPair: SslPropertiesBuilderPair? = null
internal var consumerSslPropertiesBuilderPair: SslPropertiesBuilderPair? = null
internal var schemaRegistryClientSslPropertiesBuilder: SslPropertiesBuilder? = null

// SASL Configurations
internal var commonSaslPropertiesBuilderPair: SaslPropertiesBuilderPair? = null
internal var adminSaslPropertiesBuilder: SaslPropertiesBuilderPair? = null
internal var adminSaslPropertiesBuilderPair: SaslPropertiesBuilderPair? = null
internal var producerSaslPropertiesBuilderPair: SaslPropertiesBuilderPair? = null
internal var consumerSaslPropertiesBuilderPair: SaslPropertiesBuilderPair? = null
internal var schemaRegistryClientSaslPropertiesBuilder: SaslPropertiesBuilder? = null
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,8 +76,8 @@ fun KafkaConfig.commonSsl(configuration: SslPropertiesBuilderPair.() -> Unit) {
* Sets a specific SSL configuration for the admin client.
*/
@KafkaDsl
fun KafkaConfig.adminSsl(configuration: SslPropertiesBuilder.() -> Unit) {
adminSslPropertiesBuilder = SslPropertiesBuilder().apply(configuration)
fun KafkaConfig.adminSsl(configuration: SslPropertiesBuilderPair.() -> Unit) {
adminSslPropertiesBuilderPair = SslPropertiesBuilderPair().apply(configuration)
}

/**
Expand Down Expand Up @@ -117,7 +117,7 @@ fun KafkaConfig.commonSasl(configuration: SaslPropertiesBuilderPair.() -> Unit)
*/
@KafkaDsl
fun KafkaConfig.adminSasl(configuration: SaslPropertiesBuilderPair.() -> Unit) {
adminSaslPropertiesBuilder = SaslPropertiesBuilderPair().apply(configuration)
adminSaslPropertiesBuilderPair = SaslPropertiesBuilderPair().apply(configuration)
}

/**
Expand Down

0 comments on commit 4b3ba32

Please sign in to comment.