У нас есть требование повторно использовать KTable (Gender) в нескольких классах путем наследования от родительского класса, но когда мы создаем связь наследования, то это показывает ошибку Topi c уже зарегистрировано другим источником I Передаю параметр строителя из одноэлементного объекта. Как это может быть возможно в двух разных классах?
object app{
def main{
builder properties .....
new Parent(builder).test()
new child(builder).testing()
}
}
Class Parent(builder : StreamBuilder) {
val gender : KTable = ........
}
Class child(builder : StreamBuilder) extends Parent(builder){
gender.tostream.peek((k,v) => println(v))
}