namespace JiShe.CollectBus.Kafka.Internal;

public interface ISubscribeAck
{
    /// <summary>
    ///     是否成功标记
    /// </summary>
    bool Ack { get; set; }

    /// <summary>
    ///     消息
    /// </summary>
    string? Msg { get; set; }
}