Changes to handle Exception::ImmutableAttributeModification
Added a simple query for Kafka server