class KafkaOperationsFactory {

    public KafkaOperations create(final Cluster cluster, final long userId) {
        final String clientId = getClientId(userId);

        // Create new Operational Client
        final ClusterConfig clusterConfig = ClusterConfig.newBuilder(cluster, secretManager).build();
        final AdminClient adminClient = kafkaAdminFactory.create(clusterConfig, clientId);
        final KafkaConsumer<String, String> kafkaConsumer = kafkaAdminFactory.createConsumer(clusterConfig, clientId);

        return new KafkaOperations(adminClient, kafkaConsumer);
    }

    public  KafkaOperationsFactory(final SecretManager secretManager, final KafkaAdminFactory kafkaAdminFactory);

}