diff --git a/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs b/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs
index a914df6..06ec6e6 100644
--- a/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs
+++ b/src/DotNetCore.CAP.Kafka/CAP.SubscribeAttribute.cs
@@ -6,35 +6,35 @@ namespace DotNetCore.CAP
public class CapSubscribeAttribute : TopicAttribute
{
public CapSubscribeAttribute(string name)
- : this(name, 0)
+ : base(name)
{
}
- ///
- /// Not support
- ///
- public CapSubscribeAttribute(string name, int partition)
- : this(name, partition, 0)
- {
- }
+ /////
+ ///// Not support
+ /////
+ //public CapSubscribeAttribute(string name, int partition)
+ // : this(name, partition, 0)
+ //{
+ //}
- ///
- /// Not support
- ///
- public CapSubscribeAttribute(string name, int partition, long offset)
- : base(name)
- {
- Offset = offset;
- Partition = partition;
- }
+ /////
+ ///// Not support
+ /////
+ //public CapSubscribeAttribute(string name, int partition, long offset)
+ // : base(name)
+ //{
+ // Offset = offset;
+ // Partition = partition;
+ //}
- public int Partition { get; }
+ //public int Partition { get; }
- public long Offset { get; }
+ //public long Offset { get; }
- public bool IsPartition => Partition == 0;
+ //public bool IsPartition => Partition == 0;
- public bool IsOffset => Offset == 0;
+ //public bool IsOffset => Offset == 0;
public override string ToString()
{