Mihai Todor

Docs for `kafka` input metadata: https://docs.redpanda.com/redpanda-connect/components/inputs/kafka/#metadata Potential utility for implementation: https://github.com/twmb/franz-go/blob/master/pkg/kadm/groups.go#L1407-L1841

Consider exposing a utility for converting between g. variants by leveraging pyliftover

6

Workaround using the existing functionality: If I have, say `var_g` = `hgvs.parser.Parser().parse_hgvs_variant('NC_000005.9:g.112090651A>G')` and I want to do liftover between assemblies, one way that seems to work is to call `vm.relevant_transcripts(var_g)`...

Add `redpanda_replicator` and `redpanda_replicator_bundle` components

2

# Demo ## Start source and sink Redpanda Docker containers ```shell > docker run --rm -it --name=source -p 8081:8081 -p 9092:9092 -p 9644:9644 redpandadata/redpanda redpanda start --node-id 0 --mode dev-container...

Deleting a stream via the REST API can block forever

1

Steps to reproduce: 1. Start Connect: ```shell > redpanda-connect streams ``` 2. Create a simple stream via the REST API with a failing output which blocks messages forever: ```shell >...