If the tuples processed by the output operator are not of type String, then
the recovery code may fail because it attempts to interpret the messages
that were already stored as String. That's a bug in the operator. The
workaround is to convert the object to String in the upstream operator and
then
Hi,
Need some help. While running DT application with “Kafka” running into issues
with application. When monitoring the application, We are observing that the
operator getting inactive and restarts continuously. Could you please refer
the below log let us know if any configuration need to be ch