private void notifyLogEventListeners(LogSegment segment, LogEventListener.Event event) {
        for (LogEventListener listener : logEventListeners) {
            try {
                listener.onChanged(segment, event);
            } catch (Throwable e) {
                LOGGER.error("got notify listener error", e);
            }
        }
    }
Calculate trim offset of each stream.

@return stream trim offset map, key is stream name, value is trim offset.
core/src/main/scala/kafka/log/streamaspect/ElasticLogSegmentManager.java