Protocols & Binary Serialization
Compruebe una clave y el total de particiones con el algoritmo Murmur2 compatible con Java.
Se conservan espacios y saltos de línea. Una clave de cero bytes es válida; elija null para una clave ausente.
68 65 6c 6c 6f
El cálculo se realiza en esta pestaña. No se envían ni guardan claves ni se conecta con un clúster Kafka.
Se aplica al enrutamiento con clave mediante Murmur2 compatible con Java. Una partición explícita, claves ignoradas u otro serializador o particionador pueden cambiar el destino real.
Cálculo completado.
Calcular partición Kafka ayuda a investigar un mensaje que llega a un destino inesperado. Primero conviene separar la clave visible de los bytes que realmente produjo la serialización. Aquí puede comparar esos bytes, el hash y el divisor antes de atribuir el problema al productor.
Una clave de partición numérica puede viajar como texto o como entero binario. No son entradas equivalentes para el hash. Si utiliza un serializador distinto del de cadenas UTF-8, introduzca su salida real en hexadecimal o Base64.
Calcular partición Kafka permite cotejar tres representaciones de la misma secuencia. La vista hexadecimal revela espacios finales, saltos de línea y caracteres de varios bytes. Cuando los bytes coinciden, la codificación usada para introducirlos no cambia el hash ni el destino con las mismas condiciones.
Una cadena UTF-8 vacía produce un array existente de cero bytes. null significa que no hay array de clave. El primero tiene un hash determinista; el segundo requiere el estado del productor. Por eso no se presenta una partición inventada para la ausencia de clave.
UTF-8 conserva espacios y saltos. Hex admite blancos ASCII, pero necesita pares completos sin 0x. Base64 estándar requiere su relleno. Cambiar la codificación vuelve a interpretar la entrada; no convierte ni sustituye automáticamente el texto.
12 es un ejemplo inicial, no una recomendación de capacidad. La numeración empieza en cero: con 12 particiones hay destinos del 0 al 11. Al cambiar el total puede cambiar el resto y el destino de futuras escrituras, aunque el hash permanezca igual.
Cargue abc o foobar desde los vectores y compare el hash con signo con el valor esperado. El modo automático espera 350 ms tras el último cambio. Desactívelo para ejecutar con Ctrl/Cmd + Intro; los resultados antiguos no se pueden exportar.
Murmur2 usa la semilla 0x9747b28c, bloques de cuatro bytes little endian y multiplicación de 32 bits. Los valores con y sin signo representan los mismos bits. Antes del módulo se elimina el bit de signo con 0x7fffffff; tomar el valor absoluto es una operación distinta.
Hex y Base64 estándar aceptan bytes arbitrarios, incluidos 00 y ff. Una cantidad impar de dígitos, relleno incorrecto o bits finales no canónicos producen un error. La herramienta tampoco cambia mayúsculas ni normaliza Unicode, evitando reparaciones silenciosas que modificarían el hash.
abc, foobar y 21 muestran los valores de referencia de Apache Kafka. La vista previa empieza con 100 bytes y se amplía de 100 en 100. El JSON conserva todos los bytes, algoritmo, codificación, tipo de clave, total de particiones y valores intermedios para compararlos con registros.
Con la política seleccionada, calcule Murmur2 sobre los bytes serializados, elimine el bit de signo y obtenga el resto respecto al total de particiones. abc tiene hash con signo 479470107 y cae en la partición 3 de 12. Confirme el total con los metadatos del tema.
Sí. Muchas claves comparten un conjunto finito de destinos. No hace falta que sus hashes completos coincidan: valores positivos distintos pueden tener el mismo resto. Compartir partición no demuestra igualdad de claves ni necesariamente una colisión del hash de 32 bits.
Compare los bytes, el total y la configuración del particionador. Distintos clientes pueden elegir algoritmos y serializadores diferentes. Una partición explícita o ignorar las claves también cambia la ruta. El rebalanceo de consumidores modifica la asignación de consumo, pero no esta fórmula de hash.
No. Depende de los requisitos de agrupación y orden de la aplicación. Se pueden enviar mensajes sin clave, aunque su destino ya no se obtiene únicamente con la fórmula Murmur2 por clave. Una cadena vacía es diferente de una clave que no existe.
Depende del cliente, la versión, la configuración y el estado de ejecución, incluidos los lotes. Los productores Java pueden emplear comportamiento sticky y otros clientes siguen políticas distintas. Esta página no asigna una partición fija a null ni supone siempre una rotación circular.
La variante de Kafka usa la semilla fija 0x9747b28c. Los mismos bytes producen el mismo hash entre ejecuciones. Eso no fija para siempre el destino: otro total de particiones cambia el módulo y otro particionador puede aplicar un algoritmo distinto.
¿Has detectado un error de cálculo o validación?
Calcular partición Kafka permite contrastar los bytes reales del serializador y sus valores intermedios con la implementación de enrutamiento del productor.