kafka module updated