(c: Composition, seed: int)
| 533 | |
| 534 | |
| 535 | def delete_sink_topic(c: Composition, seed: int) -> None: |
| 536 | c.exec("redpanda", "rpk", "topic", "delete", f"testdrive-sink-topic-{seed}") |
| 537 | |
| 538 | # Write new data to source otherwise nothing will encounter the missing topic |
| 539 | c.testdrive(schema() + dedent(""" |
| 540 | $ kafka-ingest topic=source-topic format=avro schema=${schema} |
| 541 | {"f1": "B"} |
| 542 | |
| 543 | > SELECT COUNT(*) FROM source1_tbl; |
| 544 | 2 |
| 545 | """)) |
| 546 | |
| 547 | |
| 548 | def alter_pg_table(c: Composition) -> None: |
no test coverage detected