diff --git a/lib/kafkalib/kafka.go b/lib/kafkalib/kafka.go
index 9691633c..2d168e0d 100644
--- 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
-}