Package org.springframework.cloud.stream.binder.kafka.streams

Class GlobalKTableBoundElementFactory

java.lang.Object

org.springframework.cloud.stream.binding.AbstractBindingTargetFactory<org.apache.kafka.streams.kstream.GlobalKTable>

org.springframework.cloud.stream.binder.kafka.streams.GlobalKTableBoundElementFactory

All Implemented Interfaces:

org.springframework.cloud.stream.binding.BindingTargetFactory

public class GlobalKTableBoundElementFactory
extends org.springframework.cloud.stream.binding.AbstractBindingTargetFactory<org.apache.kafka.streams.kstream.GlobalKTable>

BindingTargetFactory for GlobalKTable Input bindings are only created as output bindings on GlobalKTable are not allowed.

Since:

2.1.0

Author:

Soby Chacko

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	GlobalKTableBoundElementFactory.GlobalKTableWrapper	Wrapper for GlobalKTable proxy.

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.streams.kstream.GlobalKTable	createInput(String name)
org.apache.kafka.streams.kstream.GlobalKTable	createOutput(String name)

Methods inherited from class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory

canCreate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

createInput

public org.apache.kafka.streams.kstream.GlobalKTable createInput(String name)

Specified by:

createInput in interface org.springframework.cloud.stream.binding.BindingTargetFactory

Specified by:

createInput in class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory<org.apache.kafka.streams.kstream.GlobalKTable>

createOutput

public org.apache.kafka.streams.kstream.GlobalKTable createOutput(String name)

Specified by:

createOutput in interface org.springframework.cloud.stream.binding.BindingTargetFactory

Specified by:

createOutput in class org.springframework.cloud.stream.binding.AbstractBindingTargetFactory<org.apache.kafka.streams.kstream.GlobalKTable>