Есть ли способ использовать -K в производителе kafkacat для предоставления фиксированного ключа для всех создаваемых сообщений - PullRequest
Новая
       36

Есть ли способ использовать -K в производителе kafkacat для предоставления фиксированного ключа для всех создаваемых сообщений

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

Я использую kafkacat в качестве простого производителя. Пока все хорошо. Однако есть ли способ предоставить фиксированный ключ для всех создаваемых сообщений? Я использую опцию -K: но не работает. все в коде работает, но -K:

CODE ниже. curl -s "https://miAPI.dj" | kafkacat -b $ {CCLOUD_BROKERS} -L -X security.protocol = SASL_SSL -X sasl.mechanisms = PLAIN -X sasl.username = $ {CCLOUD_ACCESS_KEY_ID} -X sasl.password = $ {CCLOUD_SECRET_ACCESS_KEY} -X ssl.ca.location = / private / etc / ssl / cert.pem -X api.version.request = true -t персона -P -k:

I нравится эмулировать простой производитель kafka: --property "parse.key = true" --property "k.separator =:"

Мои JSon записи выглядят так: {"id": 1, " first_name ":" Уитни " "last_name": "Шихан", "электронная почта": "wsheehan0@posterous.com", "пол": "Мужской", "socialnumber": "118-04-8031", "ccnumber":" 503856879199169132" , "DOB": "2012/10/09"}

...