[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105406#comment-17105406
]
Maxim Malykhin commented on FLINK-17575:
ByteArrayDeserializer doing nothing:
{code:java}
public
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105176#comment-17105176
]
Maxim Malykhin commented on FLINK-17575:
When I disable the crc check an exception occurs that
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104896#comment-17104896
]
Maxim Malykhin commented on FLINK-17575:
I apologize for my English and for the overly emotional
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104874#comment-17104874
]
Maxim Malykhin commented on FLINK-17575:
kafka-streams has DeserializationExceptionHandler,
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104722#comment-17104722
]
Maxim Malykhin commented on FLINK-17575:
I didn't find a way to tell the kafka client to skip
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104709#comment-17104709
]
Maxim Malykhin commented on FLINK-17575:
Yes, the task was faulty and restored from the control
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104690#comment-17104690
]
Maxim Malykhin edited comment on FLINK-17575 at 5/11/20, 5:17 PM:
--
this
[
https://issues.apache.org/jira/browse/FLINK-17575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104690#comment-17104690
]
Maxim Malykhin commented on FLINK-17575:
this a "root execption" copied from flink dashboard
>
Maxim Malykhin created FLINK-17575:
--
Summary: KafkaException: Received exception when fetching the next
record from XXX-14. If needed, please seek past the record to continue
consumption.
Key: FLINK-17575
URL: