Migrated AuditJob away from KafkaScheduler (#2530)
* Migrated AuditJob away from KafkaScheduler Refactored AuditManager to inherit ShutdownableThread model reviewer: @rohitshekhar29
显示
- core/src/main/scala/kafka/durability/audit/AuditJob.scala 6 个添加, 4 个删除core/src/main/scala/kafka/durability/audit/AuditJob.scala
- core/src/main/scala/kafka/durability/audit/AuditManager.scala 41 个添加, 66 个删除.../src/main/scala/kafka/durability/audit/AuditManager.scala
- core/src/main/scala/kafka/server/KafkaServer.scala 1 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaServer.scala
- core/src/test/scala/unit/kafka/durability/DurabilityTestUtils.scala 4 个添加, 6 个删除...est/scala/unit/kafka/durability/DurabilityTestUtils.scala
- core/src/test/scala/unit/kafka/durability/audit/AuditManagerTest.scala 21 个添加, 19 个删除.../scala/unit/kafka/durability/audit/AuditManagerTest.scala
加载中
想要评论请 注册 或 登录