akkadotnet/Akka.Streams.Kafka

Bug: InvalidOperationException

Aaronontheweb opened this issue · 0 comments

We are getting a InvalidOperationException with Kafka Streams, here is the stack trace:

This operation cannot be performed on a default instance of ImmutableArray<T>. Consider initializing the array, or checking the ImmutableArray<T>.IsDefault property.
  System.InvalidOperationException: This operation cannot be performed on a default instance of ImmutableArray<T>. Consider initializing the array, or checking the ImmutableArray<T>.IsDefault property.
    at System.Collections.Immutable.ImmutableArray`1.ThrowInvalidOperationIfNotInitialized()
    at System.Collections.Immutable.ImmutableArray`1.System.Collections.Generic.IEnumerable<T>.GetEnumerator()
    at System.Linq.Enumerable.Any[TSource](IEnumerable`1 source)
    at Akka.Streams.Kafka.Stages.Consumers.Actors.KafkaConsumerActor`2.CheckRebalanceState(Boolean initialRebalanceInProgress)
    at Akka.Streams.Kafka.Stages.Consumers.Actors.KafkaConsumerActor`2.Poll()
    at Akka.Streams.Kafka.Stages.Consumers.Actors.KafkaConsumerActor`2.ReceivePoll(Poll`2 poll)
    at Akka.Streams.Kafka.Stages.Consumers.Actors.KafkaConsumerActor`2.Receive(Object message)
    at Akka.Actor.ActorBase.AroundReceive(Receive receive, Object message)
    at Akka.Actor.ActorCell.ReceiveMessage(Object message)
    at Akka.Actor.ActorCell.Invoke(Envelope envelope)

Looks like a straightforward bug, using an un-initialized variable.