@Override
        public void run() {
          ThreadUtil.logThreadDump("Thread dump at task callback timeout");
          String msg = "Callback for task {} " + callback.taskName + " timed out after " + callbackTimeout + " ms.";
          callback.failure(new SamzaException(msg));
        }
Creates a task callback.
@param taskName task name
@param envelope incoming envelope
@param coordinator coordinator
@param callbackTimeout timeout to expire the callback
samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java