Skip to content

Commit 9c618ee

Browse files
smjnsmjn
authored
MINOR: Move dlq code to server module. (#22411)
* Share group dlq code resides in the `server-common` module. It is currently needed by the implementations in `core` and `server` module. * Additionally, it has dependency on `ShareGroupMetrics` and `LogReader` which are in `server` module. * To keep the current structure, it would require adding additional dependency-breaking interfaces in `server-common`. * Instead, it is better to move the code itself to `server` as it is not needed by other kafka components. Reviewers: Apoorv Mittal <apoorvmittal10@gmail.com>
1 parent da83631 commit 9c618ee

7 files changed

File tree

server-common/src/main/java/org/apache/kafka/server/share/dlq/DefaultShareGroupDLQManager.java renamed to server/src/main/java/org/apache/kafka/server/share/dlq/DefaultShareGroupDLQManager.java

File renamed without changes.

server-common/src/main/java/org/apache/kafka/server/share/dlq/NoOpShareGroupDLQManager.java renamed to server/src/main/java/org/apache/kafka/server/share/dlq/NoOpShareGroupDLQManager.java

File renamed without changes.

server-common/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQManager.java renamed to server/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQManager.java

File renamed without changes.

server-common/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQMetadataCacheHelper.java renamed to server/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQMetadataCacheHelper.java

File renamed without changes.

server-common/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQRecordParameter.java renamed to server/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQRecordParameter.java

File renamed without changes.

server-common/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQStateManager.java renamed to server/src/main/java/org/apache/kafka/server/share/dlq/ShareGroupDLQStateManager.java

File renamed without changes.

server-common/src/test/java/org/apache/kafka/server/share/dlq/ShareGroupDLQStateManagerTest.java renamed to server/src/test/java/org/apache/kafka/server/share/dlq/ShareGroupDLQStateManagerTest.java

File renamed without changes.

0 commit comments

Comments
 (0)