Stanley Law
Stanley Law
Thanks for signing the CLA - @cla-bot check
Good Point ! I test on Python 3.13 with 3.96 MB JSON file in Jupyter notebook. And found that the `orjson` has significant improvement. 
> [!TIP] > There is a workaround solution if you facing this issue using Message Queue Trigger > ``` python > def apply_function(*args,**kwargs): > message = args[-1] > val =...
@eladkal Yes, it worked properly in 3.0.1
Oh my bad. Here is the updated repro code and exception. Will correct above message too. ``` python from confluent_kafka import Consumer c = Consumer({ 'bootstrap.servers': 'localhost:9093', 'group.id': 'confluent_kafka_test', 'auto.offset.reset':...
@vincbeck Thanks for the reviews 😄
> Thanks for the PR! > After your change, the usage is much clear. > > IMO, we should also update the `KafkaMessageQueueProvider` to reduce the inconsistency on both sides....