RiaLnN opened a new pull request, #4701: URL: https://github.com/apache/iggy/pull/4701
## Which issue does this PR address? Closes #4700 ## Rationale The Python SDK examples lacked a sink data producer for populating topics with JSON records to test sink connectors, which already existed in the Rust and Node.js examples. ## What changed? Previously, testing sink connectors from Python required writing a custom script or using the Rust/Node examples to populate the target stream and topic. examples/python/sink-data-producer/producer.py now generates 100 batches of 100–499 random JSON user records matching the Rust Record schema (user_id, user_type, email, source, state, created_at, message) using the high-level direct producer API. It reads IGGY_STREAM (default qw) and IGGY_TOPIC (default records), creates missing resources automatically, and retains the stream and topic on completion (matching the Rust behavior, documented in examples/python/README.md). ## Local Execution - Passed - Pre-commit hooks ran ## AI Usage None -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
