Tag: STRIMZI
Actualmente, este es mi código. function cleanString(rawString) { A = “ABCDEFGHIJKLMNOPQRSTUVWXYZ abcdefghijklmnopqrstuvwxyz 1234567890”.split(“”); var cleanedString = rawString.toLowerCase(); for (i = 0; i < cleanedString.length; i++) { if (!A.includes(cleanedString[i])) { cleanedString = setCharAt(cleanedString, i, ” “); } } cleanedString = cleanedString.replace(/\s\s+/g, ” “); return cleanedString; } function setCharAt(str, index, chr) { . . . Read more
public static String TrimLeft(String word) { int numberOfLetters = 0; for (char c : word.toCharArray()) { numberOfLetters++; } int start = 0, end = numberOfLetters – 1; String b = “”; for (int i = 0; i < numberOfLetters; i++) { if (!Character.isWhitespace(word.charAt(i))) { start = i; b += word.charAt(i); . . . Read more
Tenemos un clúster de MongoDB con tres réplicas. He habilitado TLS preferido y el tipo de autenticación como MongoDB-X509. Tenemos un clúster de Kafka Strimzi con tres brokers y un clúster de conexión con todos los complementos necesarios (por ejemplo, MongoDB proporcionado por Debezium) funcionando correctamente. A continuación se muestra . . . Read more
Estoy desplegando KafkaCluster, KafkaConnect en K8s utilizando Strimzi. Imagen del Clúster del Operador Strimzi: quay.io/strimzi/operator:0.26.1 Imagen de Kafka: quay.io/strimzi/kafka:0.26.1-kafka-3.0.0. Estoy tratando de configurar KafkaConnector que se conecta a una base de datos de Postgres. Estos son mis pasos: Construir un nuevo KafkaConnect a partir de esta imagen ‘quay.io/strimzi/kafka:0.26.1-kafka-3.0.0’. Esta nueva . . . Read more
Estoy implementando KafkaConnect utilizando un Recurso Personalizado. Me gustaría montar un PersistentVolumeClaim en el clúster de Kafka Connect. La idea es que otra aplicación encargada de la transferencia de archivos coloque allí un archivo que será recogido por el conector de Kafka. Verifiqué la documentación de configuración del recurso KafkaConnect . . . Read more