[Date Prev][Date Next] [Thread Prev][Thread Next] [Date Index] [Thread Index]

Bug#1008171: python-confluent-kafka: FTBFS on big-endian



Source: python-confluent-kafka
Version: 1.7.0-1
Severity: serious
Tags: ftbfs
X-Debbugs-CC: debian-s390@lists.debian.org, olasd@debian.org

Hi Maintainer

Since the upload of 1.7.0-1, python-confluent-kafka FTBFS on s390x and
some other big-endian architectures (e.g. powerpc, ppc64) [1].  I've
copied what I hope is the relevant part of the log below.

Regards
Graham


[1] https://buildd.debian.org/status/package.php?p=python-confluent-kafka


=================================== FAILURES ===================================
__________________________________ test_purge __________________________________

    def test_purge():
        """
        Verify that when we have a higher message.timeout.ms timeout,
we can use purge()
        to stop waiting for messages and get delivery reports
        """
        p = Producer(
            {"socket.timeout.ms": 10, "error_cb": error_cb,
"message.timeout.ms": 30000}
        )  # 30 seconds

        # Hack to detect on_delivery was called because inner
functions can modify nonlocal objects.
        # When python2 support is dropped, we can use the "nonlocal"
keyword instead
        cb_detector = {"on_delivery_called": False}

        def on_delivery(err, msg):
            cb_detector["on_delivery_called"] = True
            # Because we are purging messages, we should see a
PURGE_QUEUE kafka error
            assert err.code() == KafkaError._PURGE_QUEUE

        # Our message won't be delivered, but also won't timeout yet
because our timeout is 30s.
        p.produce(topic="some_topic", value="testing", partition=9,
callback=on_delivery)
        p.flush(0.002)
        assert not cb_detector["on_delivery_called"]

        # When in_queue set to false, we won't purge the message and
get delivery callback
        p.purge(in_queue=False)
        p.flush(0.002)
>       assert not cb_detector["on_delivery_called"]
E       assert not True

tests/test_Producer.py:267: AssertionError
----------------------------- Captured stderr call -----------------------------
%5|1647555748.271|CONFWARN|rdkafka#producer-27| [thrd:app]: No
`bootstrap.servers` configured: client will not be able to connect to
Kafka cluster
=========================== short test summary info ============================
FAILED tests/test_Producer.py::test_purge - assert not True
=================== 1 failed, 61 passed, 4 skipped in 19.19s ===================


Reply to: