Преобразование значения сообщения Kafka из целого числа в строку - PullRequest
1 голос
/ 25 мая 2020

У меня в одной кафке топи есть сообщение кафка c. Один из ключей этого сообщения key=ID и значение этого ключа value=12345678910111213141.

Тип этого значения - integer. Я хочу преобразовать тип в string.

В настоящее время я делаю это каким-то хакерским способом:

  • использовать сообщение
  • преобразовать тип
  • создать сообщение в другие топи c

Есть более простой способ сделать это?

PS: У вас нет доступа к первому производителю, который отправляет сообщение как integer.

1 Ответ

0 голосов
/ 25 мая 2020

Если я правильно понимаю ваш вопрос, это будет невозможно. Что касается Kafka, все данные хранятся в байтах, и Kafka не знает, какой сериализатор использовался для генерации байтового кода.

Следовательно, вы можете десериализовать значение только так, как оно было сериализовано продюсером. Насколько я понимаю, это было сделано с помощью целочисленного сериализатора. Но поскольку у вас нет доступа к Producer, у вас нет шансов, кроме как прочитать его как целое число и впоследствии преобразовать в String.

...