4 Commits

Author	SHA1	Message	Date
Mikhail f. Shiryaev	e6f5a3f98b	Apply black formatter to all *.py files in the repo	2022-03-22 17:39:58 +01:00
Ivan Blinkov	659b467290	Update produce.py	2019-11-01 19:10:15 +03:00
Ivan	4a5832b18a	Check the time limit every (flush_interval / poll_timeout) number of rows from Kafka (#5249)	2019-05-14 18:52:03 +03:00
Ivan Lezhankin	7723a63d0a	Add helper utils to interact with Kafka broker	2019-04-18 17:36:51 +03:00