flink 1.9????????kafkaSemantic??????EXACTLY_ONCE????????????????????????????1.11?? ,checkpoints??????????InitProducerId??????????????TransactionTimeout??MaxBlockMS???? org.apache.kafka.common.errors.TimeoutException: Timeout expired after 600000milliseconds while awaiting InitProducerId ????????kafka????????????????????????????????????????kafka??????????offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1 transaction.state.log.min.isr=1
