kafka-consumer-api

1зной

1ответ

Не найдено ни одного приложения для журнала (org.apache.kafka.clients.producer.ProducerConfig)

Я пишу код, в котором я пытаюсь использовать сообщения, используя kafka и искру. Но мой код не работает. Вот мой код: import org.apache.kafka.clients.producer.{ KafkaProducer, ProducerConfig, Producer

scala apache-spark apache-kafka kafka-consumer-api kafka-producer-api 2017-01-14

---

1зной

1ответ

Как я могу получить список всех групп с kafka0.10.x

, когда я использую kafka0.8.x, я могу получить список всех групп с zookeeper по пути «/ consumer/group_id», потому что смещения будут фиксировать zookeeper в 0.8 .Икс. Но в версии 0.10.x смещения, на

apache-kafka apache-zookeeper kafka-consumer-api apache-kafka-connect 2017-01-16

---

0зной

4ответ

Apache Kafka Заказ поставки

Предположим, что у меня есть производитель Kafka. Мой потребитель сначала пишет сообщение M1 в тему T1 на Kafka (через sync api), затем записывает сообщение M2 в тему T2. В то время потребитель прослу

apache-kafka kafka-consumer-api 2017-01-16

---

0зной

1ответ

Как получить текущее смещение в Kafka 0.10.x без оболочки?

Есть ли способ получить текущее смещение в Kafka 0.10.x? Я не хочу использовать команды оболочки. Когда я использую API consumer.endOffsets(...), я могу получить последние смещения (logSize). Однако c

apache-kafka kafka-consumer-api 2017-01-17

---

0зной

2ответ

Как получить смещение потребителя Кафки?

Работа с Kafka (v2.11-0.10.1.0) -spark-streaming (v-2.0.1-bin-hadoop2.7). У меня есть Kafka Producer и Spark-streaming потребитель для производства и потребления. Все работает нормально, пока я не ост

apache-kafka spark-streaming kafka-consumer-api kafka-producer-api 2017-01-18

---

0зной

2ответ

Turnoff Kafka, Scala Logging

Как отключить следующий журнал? INFO [main] (Logging.scala:68) - pnsender-pc_TT11015507S-1484737874302-c6f061bf-0 attempting to claim partition 3 INFO [main] (Logging.scala:68) - pnsender-pc_TT110155

java logging apache-kafka kafka-consumer-api kafka-producer-api 2017-01-18

---

3зной

1ответ

Портирование приложения от Kafka 0.8.2.1 до Kafka 0.9.0. Чтение смещений выпуск

у нас возникла проблема, связанная с переносом кода нашего приложения с версии 0.8.2.1 до 0.9.0.0 от Apache Kafka. Мы имеем в виду, в данном случае, до версии Кафки выпущен Cloudera: kafka_2.10-0.8.2.

scala apache-spark apache-kafka kafka-consumer-api 2017-01-18

---

1зной

2ответ

Kafka Producer Consumer API Issue

Я использую Kafka v0.10.0.0 и создал Продюсер & Потребительский Java-код. Но код застрял на производителю. Без каких-либо исключений в журналах. Может ли кто-нибудь помочь. Заранее спасибо. Я использу

apache-kafka kafka-consumer-api kafka-producer-api 2017-01-19

---