Job does not get pushed to queue.

[naneri]

I am trying to push the job to the queue, here is what I get in the output:

%7|1606284122.968|DESTROY|rdkafka#consumer-10| [thrd:app]: Terminating instance (destroy flags none (0x0))
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Terminating consumer group handler
%7|1606284122.968|CLOSE|rdkafka#consumer-10| [thrd:app]: Closing consumer
%7|1606284122.968|CLOSE|rdkafka#consumer-10| [thrd:app]: Waiting for close events
%7|1606284122.968|CGRPOP|rdkafka#consumer-10| [thrd:main]: Group "test-group" received op TERMINATE in state init (join-state init)
%7|1606284122.968|CGRPTERM|rdkafka#consumer-10| [thrd:main]: Terminating group "test-group" in state init with 0 partition(s)
%7|1606284122.968|CLEARASSIGN|rdkafka#consumer-10| [thrd:main]: No current assignment to clear
%7|1606284122.968|DUMP|rdkafka#consumer-10| [thrd:main]: Assignment dump (started_cnt=0, wait_stop_cnt=0)
%7|1606284122.968|DUMP_ALL|rdkafka#consumer-10| [thrd:main]: List with 0 partition(s):
%7|1606284122.968|DUMP_PND|rdkafka#consumer-10| [thrd:main]: List with 0 partition(s):
%7|1606284122.968|DUMP_QRY|rdkafka#consumer-10| [thrd:main]: List with 0 partition(s):
%7|1606284122.968|DUMP_REM|rdkafka#consumer-10| [thrd:main]: List with 0 partition(s):
%7|1606284122.968|ASSIGNDONE|rdkafka#consumer-10| [thrd:main]: Group "test-group": assignment operations done in join-state init (rebalance rejoin=false)
%7|1606284122.968|CGRPSTATE|rdkafka#consumer-10| [thrd:main]: Group "test-group" changed state init -> term (join-state init)
%7|1606284122.968|BROADCAST|rdkafka#consumer-10| [thrd:main]: Broadcasting state change
%7|1606284122.968|ASSIGNMENT|rdkafka#consumer-10| [thrd:main]: Group "test-group": clearing group assignment
%7|1606284122.968|CLOSE|rdkafka#consumer-10| [thrd:app]: Consumer closed
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Interrupting timers
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Sending TERMINATE to internal main thread
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Joining internal main thread
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:main]: Internal main thread terminating
%7|1606284122.968|DESTROY|rdkafka#consumer-10| [thrd:main]: Destroy internal
%7|1606284122.968|BROADCAST|rdkafka#consumer-10| [thrd:main]: Broadcasting state change
%7|1606284122.968|DESTROY|rdkafka#consumer-10| [thrd:main]: Removing all topics
%7|1606284122.968|DESTROY|rdkafka#consumer-10| [thrd:main]: Sending TERMINATE to [47.245.57.245:9094/bootstrap
%7|1606284122.968|DESTROY|rdkafka#consumer-10| [thrd:main]: Sending TERMINATE to GroupCoordinator
%7|1606284122.968|TERM|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1606284122.968|TERM|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1606284122.968|FAIL|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Client is terminating (after 2ms in state INIT) (_DESTROY)
%7|1606284122.968|STATE|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Broker changed state INIT -> DOWN
%7|1606284122.968|BROADCAST|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: Broadcasting state change
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Updating 0 buffers on connection reset
%7|1606284122.968|FAIL|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Client is terminating (after 2ms in state INIT) (_DESTROY)
%7|1606284122.968|STATE|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Broker changed state INIT -> DOWN
%7|1606284122.968|BROADCAST|rdkafka#consumer-10| [thrd:GroupCoordinator]: Broadcasting state change
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Handle is terminating in state DOWN: 1 refcnts (0x7ffcaf822d98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1606284122.968|FAIL|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Purging bufq with 0 buffers
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:main]: Purging reply queue
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Handle is terminating in state DOWN: 1 refcnts (0x7ffcb0014798), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:main]: Decommissioning internal broker
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:[47.245.57.245:9094/bootstrap]: [47.245.57.245:9094/bootstrap: Updating 0 buffers on connection reset
%7|1606284122.968|FAIL|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd:GroupCoordinator]: GroupCoordinator: Updating 0 buffers on connection reset
%7|1606284122.968|TERM|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Received TERMINATE op in state INIT: 1 refcnts, 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs
%7|1606284122.968|FAIL|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Client is terminating (after 2ms in state INIT) (_DESTROY)
%7|1606284122.968|STATE|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Broker changed state INIT -> DOWN
%7|1606284122.968|BROADCAST|rdkafka#consumer-10| [thrd::0/internal]: Broadcasting state change
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:main]: Join 3 broker thread(s)
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Handle is terminating in state DOWN: 1 refcnts (0x7ffcaf823f98), 0 toppar(s), 0 active toppar(s), 0 outbufs, 0 waitresps, 0 retrybufs: failed 0 request(s) in retry+outbuf
%7|1606284122.968|FAIL|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Broker handle is terminating (after 0ms in state DOWN) (_DESTROY)
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Purging bufq with 0 buffers
%7|1606284122.968|BUFQ|rdkafka#consumer-10| [thrd::0/internal]: :0/internal: Updating 0 buffers on connection reset
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:main]: Internal main thread termination done
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Destroying op queues
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Destroying cgrp
%7|1606284122.968|MEMBERID|rdkafka#consumer-10| [thrd:app]: Group "test-group": updating member id "" -> "(not-set)"
%7|1606284122.968|TERMINATE|rdkafka#consumer-10| [thrd:app]: Termination done: freeing resources
%4|1606284122.968|TERMINATE|rdkafka#producer-9| [thrd:app]: Producer terminating with 1 message (541 bytes) still in queue or transit: use flush() to wait for outstanding message delivery

but the queue is empty.