Sergio Gómez Villamor a8637abfe2

tests(kafka): fixing flaky tests (#13171)

2025-04-22 12:58:47 +02:00

..

broker.env

chore(ingest): change kafka connect mapped ports (#7728)

2023-04-04 18:38:30 +05:30

create_key_value_topic.py

fix(ingest): fixing support for kafka key schemas when only key schemas are present (#3379)

2021-10-12 18:50:39 -07:00

docker-compose.yml

tests(kafka): fixing flaky tests (#13171)

2025-04-22 12:58:47 +02:00

kafka_mces_golden.json

feat(ingestion/kafka)-Add support for ingesting schemas from schema registry (#10612)

2024-06-11 14:00:12 +02:00

kafka_to_file_oauth.yml

fix(ingestion/kafka): OAuth callback execution (#11900)

2024-11-22 13:08:23 +05:30

kafka_to_file.yml

feat(ingest/kafka): Flag for optional schemas ingestion (#12077)

2024-12-11 16:02:31 +00:00

kafka_without_schemas_mces_golden.json

feat(ingest/kafka): Flag for optional schemas ingestion (#12077)

2024-12-11 16:02:31 +00:00

kafka_without_schemas_to_file.yml

feat(ingest/kafka): Flag for optional schemas ingestion (#12077)

2024-12-11 16:02:31 +00:00

key_schema.avsc

feat(ingestion/kafka): add description in dataset properties (#7974)

2023-05-17 11:03:08 -07:00

oauth.py

feat(ingest/kafka): additional validation for oauth_db signature (#11996)

2024-12-05 12:41:43 +05:30

schema-registry.env

feat: Adding support for nested schemas in ingestion and visualization (#3079)

2021-08-11 15:47:18 -07:00

send_records.sh

chore(ingest): change kafka connect mapped ports (#7728)

2023-04-04 18:38:30 +05:30

test_kafka_state.py

chore(ingest): run pyupgrade for python 3.8 (#10513)

2024-05-15 22:31:05 -07:00

test_kafka.py

tests(kafka): fixing flaky tests (#13171)

2025-04-22 12:58:47 +02:00

value_schema.avsc

feat(ingest/kafka): support metadata mapping from kafka avro schemas (#8825)

2023-09-22 17:11:42 -07:00

zookeeper.env

feat: Adding support for nested schemas in ingestion and visualization (#3079)

2021-08-11 15:47:18 -07:00