vishal singh
vishal singh
@jason19970210 use .flush() on producer at the end. ``` if __name__ == '__main__': producer.send(topic, value=b'message') producer.flush() ``` for content KafkaProducer send message in async call, first add message in local...
We can include it, but it will only function with models that support structured output.