sjhajharia commented on code in PR #17775:
URL: https://github.com/apache/kafka/pull/17775#discussion_r1908544013
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java:
##########
@@ -175,6 +189,8 @@ public GroupCoordinatorService build() {
throw new IllegalArgumentException("GroupCoordinatorMetrics
must be set.");
if (groupConfigManager == null)
throw new IllegalArgumentException("GroupConfigManager must be
set.");
+ if (persister == null)
+ throw new IllegalArgumentException("Persister must be set.");
Review Comment:
Right now yes.
We may remove this condition here though. I will check that again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
