What's new in Cloudera Streaming Analytics

Cloudera Streaming Analytics 1.6.2 covers new features beside the core streaming functionality of Apache Flink and SQL Stream Builder.

Configuring deserialization failures for Kafka tables

Support for configuring error handling of deserialization is added. When using the Kafka connector with any data type, you can choose from the following options how to handle schema mismatch error:

• Throw an exception
• Ignore the message
• Ignore the message and log the error
• Ignore the message in the context of the current stream, but store it in a dead-letter queue topic