Skip to content

KafkaConsumer.CommittablePartitionedSource sub stream failure #413

@Arkatufus

Description

@Arkatufus

There are evidence that attributes being passed to the source were not being passed on correctly to the source of the partition sub-stream. A failing sub-stream did not use the same supervisor directive as the parent stream. This was observed when OnDeserializationError was used to log bad messages and the decider was supposed to use Directive.Resume instead of stop.

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions