pybgpstream collector filter not working

[Tf-arch]

I want to collect live BGP data and
and following code working fine

import pybgpstream
stream = pybgpstream.BGPStream(
# accessing ris-live
project="ris-live",

)

for elem in stream:
print(elem)

but when I add collector option of filter on collector basis then It gives no output and after some time

2024-12-17 15:13:57 4827: bs_transport_kafka.c:145: ERROR: Local: Message timed out (-192): 128.223.51.38:9092/0: 1 request(s) timed out: disconnect (average rtt 605.710ms)
2024-12-17 15:14:27 4827: bs_transport_kafka.c:145: ERROR: Local: Message timed out (-192): 128.223.51.38:9092/0: 1 request(s) timed out: disconnect (average rtt 605.159ms)

I tried but .. (not working)

import pybgpstream
stream = pybgpstream.BGPStream(
# accessing ris-live
project="ris-live",
# filter to show only stream from rrc00
filter="collector rrc00",
)

for elem in stream:
print(elem)
and also

import pybgpstream
stream = pybgpstream.BGPStream(
# accessing ris-live
project="ris-live",
# filter to show only stream from rrc00
collectors=["rrc00"]
)

for elem in stream:
print(elem)