kafka-producer-api

2зной

3ответ

Kafka DefaultPartitioner agorithm

Существует очень маленькая, но очень мощная деталь в реализации Kafka org.apache.kafka.clients.producer.internals.DefaultPartitioner, которая меня сильно задевает. Именно эта строка кода: return Defau

apache-kafka kafka-producer-api 2016-09-30

---

0зной

1ответ

KafkaProducer как переменная трансляции в интеграции Kafka-Spark

Я пытаюсь читать из Kafka и передавать данные в другую очередь kakfa с помощью Spark. Мой первоначальный подход заключается в создании объекта KafkaProducer для каждой записи в разделе RDD, и он работ

apache-spark apache-kafka spark-streaming kafka-producer-api apache-spark-standalone 2016-10-01

---

1зной

1ответ

Kafka - Разница между DefaultPartitioner с MessageKey vs Custom Partitioner?

Я пытаюсь отправить сообщение KafkaProducer с помощью ProducerRecord. new ProducerRecord(topicName,messageKey,message) Это использует DefaultPartitioner, DefaultPartitioner будет использовать хэш кл

apache-kafka kafka-producer-api 2016-10-05

---

0зной

2ответ

При использовании Kafka High Level ConsumerConnector, где будут храниться смещения?

Как показывает новый документ, Kafka сам позаботится об управлении смещениями при использовании API высокого уровня по умолчанию. Но когда я создаю ConsumerConnector, как показано ниже, мне по-прежнем

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect 2016-10-12

---

1зной

1ответ

Кафка Производитель RecordTooLargeException

Я получаю следующее сообщение об ошибке org.apache.kafka.common.errors.RecordTooLargeException: Послание 196773 байт при сериализовать, который больше, чем общий буфер памяти вы настроили с buffer.mem

apache-kafka kafka-producer-api 2016-10-13

---