| 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 |