是否可以使用kafka消息代理按用户名加载用户？
例如：我有两个应用程序：一个用于身份验证和授权，另一个用于从数据库接收用户。我想使用kafka消息代理在这些应用程序之间创建连接。
Web安全配置.java

@Configuration
@RequiredArgsConstructor
public class WebSecurityConfig extends WebSecurityConfigurerAdapter {

    private final CustomUserDetailsService customUserDetailsService;

    @Override
    protected void configure(AuthenticationManagerBuilder auth) throws Exception {
        auth.userDetailsService(customUserDetailsService);
    }
}

customuserdetailsservice.java

@Component
@RequiredArgsConstructor
public class CustomUserDetailsService implements UserDetailsService {

    private final KafkaTemplate<String, String> kafkaTemplate;

    @Override
    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {

        kafkaTemplate.send("username", username);

        // I want to create a listener and return value here
        return null; // what should I do right here
    }
}

谢谢你的回答。