tree 7a77c0cfc6ad5534539cc3908a8b3aa6fa02a685
parent c81b831d5fe08d328251d91f4f255b1508a9feb4
author syhily <syhily@gmail.com> 1631522408 +0800
committer Xintong Song <tonysong820@gmail.com> 1631583504 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 iQIzBAABCgAdFiEEGsvLF58sbVnbyFd20SHP9Sk+Y18FAmE//SIACgkQ0SHP9Sk+
 Y1+ukg//eAm5TU41Hj5Ze+bQXj7hnqL5anYk4FERXFc1Ng95NEfvrOqmx/jG9Ul4
 BITNm9gEhm4zZgcqDgsbs32Cwukc1Dx2rBsFSXuxgFZ0hMA3qHj6vPSTcmom0Grc
 SkMQeznWZWGG1LLT6peCl0vLG26+DAqv1VRUK58iX+ReJfpGHNiRRWjcJIwImoTQ
 5XJIGcbjFaDZgYqhIBjtMcz+kUDxzIoaUP19lpoM/REm3QgKgHlfIFQKJJ4Tn7c6
 Vn1/jSOLqLa82pVmoIkfD2hdtRRGk1hile7cgaPCtW5zrRjr4J/mCN61tnU7Zfcj
 aw7u6Qrp//VUtJ5kJ8THSyGkl3e+L7sysKBizsJugFEiDWCY56Bjriul7xagQTvs
 iEAwmMiXbhNq/74pFwYceEcd4/zCsywJSyGWisfWx11o6BKSuiMhGEDHFW0qq6KO
 3h4RwAWNlC/Lj2yJP0stvve9ObMX/WYFi5n/FdVieNgI1d7hzzw+AfymUizkckqN
 luGBJfdftMahe9PUT6MRFVAIj0qVLv5zOhGW2Ug7Sw1AInjM2QB75D1zwscwsSks
 SVqHrLjL4QGVkETK02jKm7NImVu9kheVDziQ3/CjhrEJq23kVIULfxuMd1ap2uJr
 18YWNii3beuJqRXkjkqtP0ugtcLOa0A8rUwpUZU9tIykRdSfmko=
 =CwPn
 -----END PGP SIGNATURE-----

[FLINK-24206][connector/pulsar] Close the pulsar client properly.

Pulsar Consumer would be closed in SplitReader if it reaches the end of split. The registered Consumer would also be closed in PulsarClient if we call PulsarClient.close(). This would cause race condition. We have to use PulsarClient.shutdown() which don't close Consumer instead.

This closes #17255