Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
¿Es un anti-patrón tener el mismo tema de entrada y salida cuando se usan funciones de Pulsar? En mi caso, he estado utilizando solo un tema donde tengo un consumidor de Cassandra que consume los mensajes. Estaba pensando en crear una función que lea los mensajes de este tema y . . . Read more
Estoy curioso acerca de cómo funciona la compresión en Pulsar. Según la documentación pública, se indica que “Puedes comprimir los mensajes publicados por los productores durante el transporte”. ¿Significa eso que el cliente comprime los datos y luego se descomprimen cuando llegan al broker, de modo que los datos descomprimidos . . . Read more
¿Es posible reproducir mensajes antiguos (dentro del período de retención)? No hay documentación al respecto. Me gustaría hacer esto basándome en un sello de tiempo o período determinado. Cualquier indicio en la dirección correcta sería muy apreciado.
Estoy utilizando Pulsar para la comunicación entre servicios y estoy experimentando inestabilidad en una prueba bastante simple de productores y consumidores. En la prueba JUnit 4, inicio (mis propios envoltorios alrededor de) un servidor ZooKeeper, un servidor BookKeeper y un PulsarService; Las configuraciones deberían ser bastante estándar. La prueba se . . . Read more
Tengo un caso de uso en el que se requiere una copia de seguridad de datos en múltiples centros de datos y se necesita una alta consistencia. La vista ideal es que cada segmento se replique en tres grupos ubicados en tres centros de datos diferentes. Pulsar admite el uso . . . Read more