return Objects.hash(outputDataType,topic,properties,decodingFormat,startupMode,specificStartupOffsets,startupTimestampMillis); | return Objects.hash(outputDataType,topics,topicPattern,properties,decodingFormat,startupMode,specificStartupOffsets,startupTimestampMillis); | Objects.hash(outputDataType,topic,properties,decodingFormat,startupMode,specificStartupOffsets,startupTimestampMillis) | Objects.hash(outputDataType,topic,topic,properties,decodingFormat,startupMode,specificStartupOffsets,startupTimestampMillis) | flink | b8ee51b832d00d4615e249f384e13dcaa1f14ddf | org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicSourceBase | | | TCIVar | topic |
---|
v0 | properties |
---|
v1 | startupTimestampMillis |
---|
v2 | startupMode |
---|
v3 | specificStartupOffsets |
---|
v4 | decodingFormat |
---|
v5 | outputDataType |
---|
| | TCIVar | topic |
---|
v0 | properties |
---|
v1 | startupTimestampMillis |
---|
v2 | startupMode |
---|
v3 | specificStartupOffsets |
---|
v4 | decodingFormat |
---|
v5 | outputDataType |
---|
| Uses | True |