[bugfix] Kafka: batch + retry offsets_for_times to survive broker timeouts#547

tiankongdeguiji merged 2 commits into

alibaba:masteralibaba/TorchEasyRec:masterfrom

tiankongdeguiji:kafka_offsets_for_times_batch_retrytiankongdeguiji/TorchEasyRec:kafka_offsets_for_times_batch_retryCopy head branch name to clipboard