repositories {
    maven {
        url = uri("https://jitpack.io")
    }
}

dependencies{
    implementation("com.github.gAmUssA:ktor-kafka:main-SNAPSHOT")
}

import io.confluent.developer.ktor.Kafka
import io.confluent.developer.ktor.newTopic

fun Application.module(){

    //install Kafka feature
    install(Kafka) {
        configurationPath = "src/main/resources/kafka.conf"
        topics = listOf(
            newTopic("myTopic") {
                partitions = 3
                replicas = 1
            }
        )
    }
}