Kafka-python: ошибка при указании раздела в производителе kafka
Я пытаюсь вставить данные в другой раздел по той же теме. Я использую python-kafka 1.4.3 на Linux-машине
from kafka import KafkaProducer
producer = KafkaProducer()
producer.send(topic='test', value=b'test', partition=1)
Получение ошибки: AssertionError: нераспознанный раздел
Ответы 3
Наиболее вероятная причина в том, что в вашей теме 1 раздел, а номера разделов начинаются с 0 ...
Что ты имеешь ввиду определить с python-kafka ??? Сколько разделов у вас в теме?
Сначала проверьте, каково общее количество разделов этой темы.
Во-вторых, количество разделов начинается с 0.
producer.send(topic='test', value=b'test', partition=1)
Приведенный выше код вставит данные в РАЗДЕЛ 2. Если вы хотите вставить данные в раздел 1, просто выполните partition = 0
Создайте тему с 2 разделами. Счетчик разделов начинается с 0. Таким образом, будет два раздела 0 и 1.
Когда вы это делаете,
producer.send(topic='test', value=b'test', partition=1), это в основном означает, что вы помещаете СООБЩЕНИЕ в ТЕМУ в РАЗДЕЛ с ИНДЕКСОМ 1.Таким образом, вы можете создать TOPIC с 2 разделами, а затем поместить данные в раздел с индексом 1. Или вы можете указать partition = 0 (по умолчанию будет 1 раздел для каждой темы).
Можно ли определить это с помощью python-kafka ??