kafka consumer which detects email change in customer profile update