Fix typo in enum variable name

e2e/endtoend_message.go

@@ -4,8 +4,8 @@ import "time"
 
 const (
 	_ = iota
-	EndToEndeMessageStateCreated
-	EndToEndeMessageStateProducedSuccessfully
+	EndToEndMessageStateCreated
+	EndToEndMessageStateProducedSuccessfully
 )
 
 type EndToEndMessage struct {

e2e/message_tracker.go

@@ -128,6 +128,6 @@ func (t *messageTracker) onMessageExpired(_ string, reason ttlcache.EvictionReas
 		zap.Int64("age_ms", age.Milliseconds()),
 		zap.Int("partition", msg.partition),
 		zap.String("message_id", msg.MessageID),
-		zap.Bool("successfully_produced", msg.state == EndToEndeMessageStateProducedSuccessfully),
+		zap.Bool("successfully_produced", msg.state == EndToEndMessageStateProducedSuccessfully),
 	)
 }

e2e/producer.go

@@ -57,7 +57,7 @@ func (s *Service) produceMessage(ctx context.Context, partition int) {
 			// produced successfully, but it got lost somewhere.
 			// We need to use updateItemIfExists() because it's possible that the message has already been consumed
 			// before we have received the message here (because we were awaiting the produce ack).
-			msg.state = EndToEndeMessageStateProducedSuccessfully
+			msg.state = EndToEndMessageStateProducedSuccessfully
 			s.messageTracker.updateItemIfExists(msg)
 		}
 
@@ -72,7 +72,7 @@ func createEndToEndRecord(minionID string, topicName string, partition int) (*kg
 		Timestamp: time.Now().UnixNano(),
 
 		partition: partition,
-		state:     EndToEndeMessageStateCreated,
+		state:     EndToEndMessageStateCreated,
 	}
 
 	mjson, err := json.Marshal(message)