02700-MM-8366 confluent-kafka-connect-standaloneサービス停止時のWARNログ出力を抑止

■問題

SheltyManagerで動作する confluent-kafka-connect-standaloneサービスの停止時に、不要なWARNログ出力が行われていたのを抑止しました。

2023-12-21 10:25:09.695,83121,WARN,(shelty-sink-txds) failed to put records(java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@796ff9d0 rejected from java.util.concurrent.ScheduledThreadPoolExecutor@381de7c7[Shutting down, pool size = 2, active threads = 1, queued tasks = 135, completed tasks = 4926992]
2023-12-21 10:25:09.697,83121,WARN,(shelty-sink-txds) failed to put records(java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@27e78bc rejected from java.util.concurrent.ScheduledThreadPoolExecutor@381de7c7[Shutting down, pool size = 2, active threads = 1, queued tasks = 135, completed tasks = 4926992]
2023-12-21 10:25:09.798,83121,WARN,(shelty-sink-txds) failed to put records(java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@7b772242 rejected from java.util.concurrent.ScheduledThreadPoolExecutor@381de7c7[Shutting down, pool size = 2, active threads = 0, queued tasks = 135, completed tasks = 4926993]
2023-12-21 10:25:09.808,83121,WARN,(shelty-sink-txds) failed to put records(java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@3c00e8bc rejected from java.util.concurrent.ScheduledThreadPoolExecutor@381de7c7[Shutting down, pool size = 2, active threads = 0, queued tasks = 135, completed tasks = 4926993]
2023-12-21 10:25:09.860,83121,WARN,(shelty-sink-txds) failed to put records(java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@14b1bbbd rejected from java.util.concurrent.ScheduledThreadPoolExecutor@381de7c7[Shutting down, pool size = 2, active threads = 0, queued tasks = 135, completed tasks = 4926993]

‌

■条件

Sheltyバージョン：1.0.0以降

‌

■原因

confluent-kafka-connect-standaloneサービスでは、スケジューラを用いたメソッドログのアーカイブ処理が動作しています。
サービス停止時の内部処理の進行上、スケジューラ停止後にも新たにメソッドログのアーカイブ処理が追加されようとした際に、受け付けらないためWARNログが出力されていました。

これらのメソッドログは、次のconfluent-kafka-connect-standalone開始時にアーカイブが行われるため実際には影響はなく、不要なログ出力のみが行われる状態となっていました。

‌

■修正内容

ロジック修正を行いました。

‌

■使用方法

Managerバージョンアップにより機能変更が反映されます。