hi??I have a source Kafka and a sink Kafka??when the amount of data processing
grows??I need to expand Kafka topic's partition number ,but I don't want
to restart the job to take effect.
for source Kafka, I use flink.partition-discovery.interval-millis and it could
consume the new parititon
hi??I have a source Kafka and a sink Kafka??when the amount of data processing
grows??I need to expand Kafka topic's partition number ,but I don't want
to restart the job to take effect.
for source Kafka, I use flink.partition-discovery.interval-millis and it could
consume the new parititon
