Tag: APACHE-PULSAR
Tengo una instalación de Lucidworks Fusion 5 en kubernetes configurada en AWS EKS y actualmente uno de los servicios, Connector Classic REST service, está experimentando una interrupción. Después de revisar los registros, encontré lo siguiente: ERROR en com.lucidworks.logging.logback.PulsarAppender[PULSAR] – No se pudo conectar al tema Pulsar persistent://uat/_logs/system_logs en: pulsar://uat-pulsar-broker:6650 org.apache.pulsar.client.api.PulsarClientException$ProducerBlockedQuotaExceededError: . . . Read more
Quiero entender cómo pulsar usa debezium io connect para CDC. Al crear la fuente usando pulsar-admin source create, ¿cómo puedo pasar la URL de broker y los parámetros de autenticación o cliente? Similar a lo que hacemos al usar localrun. El comando que ejecuto: bin/pulsar-admin source localrun –sourceConfigFile debezium-mysql-source-config.yaml –client-auth-plugin . . . Read more
Creo que necesito decodificar mi archivo “.der” para usarlo como una clave pública, pero no puedo encontrar un comando “cli” para hacer esto. Me aparece el siguiente error: ” Bad Message 400 reason: Illegal character CNTL=0x2 0″ CLUSTER=standalone TENANT=sandbox NAMESPACE=integration_test AUTHORIZATION=$(cat /tmp/event-platform/oauth2_public.der) # Crear tenant curl -L -X PUT “http://localhost:$HOST_PULSAR_PORT/admin/v2/tenants/$TENANT” . . . Read more
Tengo un shell que crea un inquilino en un clúster de Pulsar. Mi pregunta es menos específica sobre eso. En el siguiente script, ¿cómo obtengo una verificación de respuesta? Me gustaría usar una condición para confirmar si el PUT recibió un 200 o no. ### ### Configurar recursos ### CLUSTER=independiente . . . Read more
¿Podemos modificar la herramienta de referencia de mensajería abierta (https://github.com/openmessaging/benchmark) para realizar pruebas de carga en la instancia independiente de Apache?