You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampipes.apache.org by "tenthe (via GitHub)" <gi...@apache.org> on 2026/05/20 11:44:16 UTC

[I] Use StreamPipes logging for KafkaPublishSink errors

tenthe opened a new issue, #4494:
URL: https://github.com/apache/streampipes/issues/4494

   ### Body
   
   In the `KafkaPublishSink` class, errors during publishing are currently only written to the service logs:
   
   ```java
   try {
     Map<String, Object> rawEvent = event.getRaw();
     this.producer.publish(dataFormatDefinition.fromMap(rawEvent));
   } catch (SpRuntimeException e) {
     LOG.error(e.getMessage(), e);
   }
   ```
   
   As a result, users are not notified when a problem occurs.
   
   This should be changed to use StreamPipes logging so that the problem appears in the UI and is visible to the user.
   
   
   ### StreamPipes Committer
   
   I acknowledge that I am a maintainer/committer of the Apache StreamPipes project.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Use StreamPipes logging for KafkaPublishSink errors

Posted by "dominikriemer (via GitHub)" <gi...@apache.org>.
dominikriemer closed issue #4494: Use StreamPipes logging for KafkaPublishSink errors
URL: https://github.com/apache/streampipes/issues/4494


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Use StreamPipes logging for KafkaPublishSink errors

Posted by "tenthe (via GitHub)" <gi...@apache.org>.
tenthe commented on issue #4494:
URL: https://github.com/apache/streampipes/issues/4494#issuecomment-4499363490

   Check whether the sink still works after editing when writing to an authenticated broker.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: issues-unsubscribe@streampipes.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org