Remove

artie-labs · Jan 25, 2024 · 93acdeb · 93acdeb
1 parent 056a2f5
commit 93acdeb
Showing 1 changed file with 0 additions and 20 deletions.
diff --git a/lib/kafkalib/kafka.go b/lib/kafkalib/kafka.go
@@ -72,23 +72,3 @@ func NewWriter(ctx context.Context, cfg config.Kafka) (*kafka.Writer, error) {
 
 	return writer, nil
 }
-
-type ReloadableWriter struct {
-	*kafka.Writer
-
-	cfg config.Kafka
-}
-
-func (w *ReloadableWriter) Reload(ctx context.Context) error {
-	if err := w.Writer.Close(); err != nil {
-		return err
-	}
-
-	writer, err := NewWriter(ctx, w.cfg)
-	if err != nil {
-		return err
-	}
-
-	w.Writer = writer
-	return nil
-}