Fix CI

Author: k-raina

src/confluent_kafka/src/Consumer.c

@@ -1575,6 +1575,7 @@ static void Consumer_rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err,
 		if (result)
 			Py_DECREF(result);
 		else {
+			
 			PyErr_Fetch(&cs->exception_type, &cs->exception_value, &cs->exception_traceback);
 			CallState_crash(cs);
 			rd_kafka_yield(rk);

src/confluent_kafka/src/Producer.c

@@ -163,6 +163,7 @@ static void dr_msg_cb (rd_kafka_t *rk, const rd_kafka_message_t *rkm,
 	if (result)
 		Py_DECREF(result);
 	else {
+		
 		PyErr_Fetch(&cs->exception_type, &cs->exception_value, &cs->exception_traceback);
 		CallState_crash(cs);
 		rd_kafka_yield(rk);

tests/test_Producer.py

@@ -296,7 +296,7 @@ def delivery_cb_that_raises(err, msg):
     producer = Producer({
         'bootstrap.servers': 'nonexistent-broker:9092',  # Will cause delivery failures
         'socket.timeout.ms': 100,
-        'message.timeout.ms': 1000,
+        'message.timeout.ms': 10,  # Very short timeout to trigger delivery failure quickly
         'on_delivery': delivery_cb_that_raises
     })
 
@@ -307,12 +307,10 @@ def delivery_cb_that_raises(err, msg):
     # Before fix: Would get RuntimeError + SystemError  
     # After fix: Should only get RuntimeError (no SystemError)
     with pytest.raises(RuntimeError) as exc_info:
-        producer.flush(timeout=1.0)
+        producer.flush(timeout=2.0)  # Longer timeout to ensure delivery callback fires
 
     # Verify we got an exception from our callback
     assert "Test exception from delivery_cb" in str(exc_info.value)
 
     # Verify the delivery callback was actually called
     assert len(delivery_reports) > 0
-    
-    producer.close()