    @Test(expected = CacheInitializationException.class)
    public void testDoubleInitialization() throws Exception {

        try (Cache<String, String> kafkaCache = createAndInitKafkaCacheInstance(bootstrapServers)) {
            kafkaCache.init();
        }
    }