Kafka KeyValueStore - 删除方法不起作用

问题描述

我正在尝试在我的一个 Kafka 处理器中安排一项任务，以从本地 keyvalueStore (RocksDB) 中删除记录。尽管到目前为止没有出现异常，但没有一条记录被删除。这是我的代码：

 let playpause_btn = document.querySelector(".playpause-track");
    let next_btn = document.querySelector(".next-track");
    let prev_btn = document.querySelector(".prev-track");

    let track_index = 0;
    let isPlaying = false;
 
 
 function playpauseTrack() {
      if (!isPlaying) playTrack();
      else pauseTrack();
    }

    function playTrack() {
      curr_track.play();
      isPlaying = true;   
  }
    
    function pauseTrack() {
      curr_track.pause();
      isPlaying = false;
  }

    function nextTrack() {
      if (track_index < track_list.length - 1) 
        track_index += 1;
      else track_index = 0;
        loadTrack(track_index);
       playTrack();    
    }

    function prevTrack() {
      if (track_index > 0)
        track_index -= 1;
      else track_index = track_list.length;
      loadTrack(track_index);
      playTrack();
    }

}

解决方法

您尚未提供有关您正在解析的日期值的任何详细信息。另外，你有没有看到日期解析失败的日志信息？多一点细节肯定会有所帮助。

根据您分享的代码片段，我假设 sentAt variable is being set as nonNull 由于异常或任何原因和 isExpired as false。

因此，您看不到任何删除操作。将调试点放在代码中以找出对象流。

这是您的 Java 代码中的问题，而不是 Kafka 状态存储。