You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Mohamed Mahmoud (El-Geish) (JIRA)" <ji...@apache.org> on 2015/04/06 23:52:12 UTC

[jira] [Created] (SAMZA-638) Add Stream Name to SystemConsumersException Message

Mohamed Mahmoud (El-Geish) created SAMZA-638:
------------------------------------------------

             Summary: Add Stream Name to SystemConsumersException Message
                 Key: SAMZA-638
                 URL: https://issues.apache.org/jira/browse/SAMZA-638
             Project: Samza
          Issue Type: Improvement
            Reporter: Mohamed Mahmoud (El-Geish)
            Priority: Minor
             Fix For: 0.10.0


Repro steps:
Point schema registry connection string to an invalid schema registry server
Run job

Expected:
Exception in thread "main" org.apache.samza.system.SystemConsumersException: Cannot deserialize an incoming message for stream: SystemName.StreamName. 
    at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:293)...

Actual:
Exception in thread "main" org.apache.samza.system.SystemConsumersException: Cannot deserialize an incoming message. 
    at org.apache.samza.system.SystemConsumers.update(SystemConsumers.scala:293)...



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)