fix: incorrect error usage and typo (#293)

Author: il-kyun

e2e/service.go

@@ -44,7 +44,7 @@ type Service struct {
 	offsetCommitLatency *prometheus.HistogramVec
 }
 
-// NewService creates a new instance of the e2e moinitoring service (wow)
+// NewService creates a new instance of the e2e monitoring service (wow)
 func NewService(ctx context.Context, cfg Config, logger *zap.Logger, kafkaSvc *kafka.Service, promRegisterer prometheus.Registerer) (*Service, error) {
 	minionID := uuid.NewString()
 	groupID := fmt.Sprintf("%v-%v", cfg.Consumer.GroupIdPrefix, minionID)
@@ -53,7 +53,7 @@ func NewService(ctx context.Context, cfg Config, logger *zap.Logger, kafkaSvc *k
 	kgoOpts := []kgo.Opt{
 		kgo.ProduceRequestTimeout(3 * time.Second),
 		kgo.RecordRetries(3),
-		// We use the manual partitioner so that the records' partition id will be used as target partitio
+		// We use the manual partitioner so that the records' partition id will be used as target partition
 		kgo.RecordPartitioner(kgo.ManualPartitioner()),
 	}
 	if cfg.Producer.RequiredAcks == "all" {

e2e/topic.go

@@ -123,7 +123,7 @@ func (s *Service) executeCreatePartitions(ctx context.Context, req *kmsg.CreateP
 	for _, topic := range res.Topics {
 		typedErr := kerr.TypedErrorForCode(topic.ErrorCode)
 		if typedErr != nil {
-			return fmt.Errorf("inner Kafka error: %w", err)
+			return fmt.Errorf("inner Kafka error: %w", typedErr)
 		}
 	}
 
@@ -397,7 +397,7 @@ func createTopicConfig(cfgTopic EndToEndTopicConfig) []kmsg.CreateTopicsRequestT
 	}
 
 	// Even though kminion's end-to-end feature actually does not require any
-	// real persistence beyond a few minutes; it might be good too keep messages
+	// real persistence beyond a few minutes; it might be good to keep messages
 	// around a bit for debugging.
 	return []kmsg.CreateTopicsRequestTopicConfig{
 		topicConfig("cleanup.policy", "delete"),