PoC: Remove older implementation

src/KafkaFlow.Abstractions/Configuration/IClusterConfigurationBuilder.cs

@@ -82,10 +82,5 @@ IClusterConfigurationBuilder CreateTopicIfNotExists(
             string topicName,
             int numberOfPartitions,
             short replicationFactor);
-
-        // Gets the cluster configuration
-        IClusterConfigurationBuilder AddInstrumentation<TConsumerInstrumentationMiddleware, TProducerInstrumentationMiddleware>()
-            where TConsumerInstrumentationMiddleware : class, IConsumerInstrumentationMiddleware
-            where TProducerInstrumentationMiddleware : class, IProducerInstrumentationMiddleware;
     }
 }

src/KafkaFlow.Abstractions/IConsumerContext.cs

@@ -75,6 +75,7 @@ public interface IConsumerContext
         /// </summary>
         void Resume();
 
+        // TODO: Need to discuss
         IReadOnlyCollection<string> Brokers { get; }
     }
 }

src/KafkaFlow.Admin.Dashboard/KafkaFlow.Admin.Dashboard.csproj

@@ -39,5 +39,5 @@
     <ProjectReference Include="..\KafkaFlow.Admin\KafkaFlow.Admin.csproj" />
     <ProjectReference Include="..\KafkaFlow\KafkaFlow.csproj" />
   </ItemGroup>
-
+  
 </Project>

src/KafkaFlow/Configuration/ClusterConfigurationBuilder.cs

@@ -98,20 +98,6 @@ public IClusterConfigurationBuilder AddConsumer(Action<IConsumerConfigurationBui
             return this;
         }
 
-        public IClusterConfigurationBuilder AddInstrumentation<TConsumerInstrumentationMiddleware, TProducerInstrumentationMiddleware>()
-            where TConsumerInstrumentationMiddleware : class, IConsumerInstrumentationMiddleware
-            where TProducerInstrumentationMiddleware : class, IProducerInstrumentationMiddleware
-        {
-            this.instrumentationConsumerMiddleware = typeof(TConsumerInstrumentationMiddleware);
-            this.instrumentationProducerMiddleware = typeof(IProducerInstrumentationMiddleware);
-
-            //this.DependencyConfigurator
-            //    .AddTransient(typeof(IConsumerInstrumentationMiddleware), this.instrumentationConsumerMiddleware)
-            //    .AddTransient(typeof(IProducerInstrumentationMiddleware), this.instrumentationProducerMiddleware);
-
-            return this;
-        }
-
         public IClusterConfigurationBuilder OnStopping(Action<IDependencyResolver> handler)
         {
             this.onStoppingHandler = handler;

src/KafkaFlow/Configuration/ConsumerConfigurationBuilder.cs

@@ -229,12 +229,6 @@ public IConsumerConfigurationBuilder WithCustomFactory(ConsumerCustomFactory cus
             return this;
         }
 
-        public void AddInstrumentation<T>(IConsumerInstrumentationMiddleware consumerInstrumentationMiddleware)
-            where T : class, IMessageMiddleware
-        {
-            var type = typeof(IConsumerInstrumentationMiddleware);            
-        }
-
         public IConsumerConfiguration Build(ClusterConfiguration clusterConfiguration)
         {
             var middlewareConfiguration = this.middlewareConfigurationBuilder.Build();

src/KafkaFlow/Configuration/MiddlewareConfigurationBuilder.cs

@@ -44,11 +44,6 @@ public TBuilder AddAtBeginning<T>(MiddlewareLifetime lifetime = MiddlewareLifeti
             return this.AddAt<T>(0, lifetime);
         }
 
-        public TBuilder AddAtBeginning(Type messageMiddleware, MiddlewareLifetime lifetime = MiddlewareLifetime.ConsumerOrProducer)
-        {
-            return this.AddAt(messageMiddleware, 0, lifetime);
-        }
-
         public IReadOnlyList<MiddlewareConfiguration> Build() => this.middlewaresConfigurations;
 
         private static InstanceLifetime ParseLifetime(MiddlewareLifetime lifetime)
@@ -97,20 +92,5 @@ private TBuilder AddAt<T>(
 
             return this as TBuilder;
         }
-
-        private TBuilder AddAt(
-            Type messageMiddleware,
-            int position,
-            MiddlewareLifetime lifetime = MiddlewareLifetime.ConsumerOrProducer)
-        {
-
-            this.DependencyConfigurator.Add(typeof(IMessageMiddleware), messageMiddleware, ParseLifetime(lifetime));
-
-            this.middlewaresConfigurations.Insert(
-                position,
-                new MiddlewareConfiguration(messageMiddleware.GetType(), lifetime));
-
-            return this as TBuilder;
-        }
     }
 }

src/KafkaFlow/Consumers/ConsumerContext.cs

@@ -39,6 +39,7 @@ public ConsumerContext(
 
         public string GroupId => this.consumer.Configuration.GroupId;
 
+        // TODO: Need to discuss
         public IReadOnlyCollection<string> Brokers => this.consumer.Configuration.ClusterConfiguration.Brokers;
 
         public bool ShouldStoreOffset { get; set; } = true;