Merge branch 'develop' of https://github.com/SoftwareAG/cumulocity-dy…

…namic-mapper into develop

dynamic-mapping-service/src/main/java/dynamic/mapping/connector/kafka/TopicConsumer.java

@@ -142,8 +142,6 @@ public void run() {
 
 				try {
 					listener.onStoppedByErrorAndReconnecting(error);
-					updateConnectorStatusToFailed(error, topicConfig.getTopic());
-
 				} catch (final Exception e) {
 					// log ("Unexpected error while onStoppedByErrorAndReconnecting() notification",
 					// e)
@@ -167,16 +165,6 @@ public void run() {
 			}
 		}
 
-		protected void updateConnectorStatusToFailed(Exception e, String topic) {
-			String msg = "Topic:" + topic + " --- " + e.getClass().getName() + ": "
-					+ e.getMessage();
-			if (!(e.getCause() == null)) {
-				msg = msg + " --- Caused by " + e.getCause().getClass().getName() + ": " + e.getCause().getMessage();
-			}
-			connectorStatus.setMessage(msg);
-			connectorStatus.updateStatus(ConnectorStatus.FAILED, false);
-		}
-
 		void close() {
 			if (closed) { // no atomicity/membars required
 				return; // since can be called only by one single thread