kafka-producer-api

0зной

2ответ

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

1зной

2ответ

Kafka Producer Consumer API Issue

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

4зной

1ответ

Конфигурация производителя Apache Kafka: VS. VS. request.timeout.ms. свойства «max.block.ms»

Учитывая под синхронной производителю Кафка Properties props = new Properties(); props.put("max.block.ms", 30000); props.put("request.timeout.ms", 30000); props.put("retries", 5); KafkaProducer<S

2зной

1ответ

Hbase Table.batch занимает 300 секунд, чтобы вставить 800 000 записей в таблицу

Я читаю json-файл размером 30 мб, обрабатываю для создания семейства столбцов и значений ключей. Затем создайте объект Put, вставьте rowkey и значения в него. Создайте список таких объектов put и вызо

1зной

1ответ

Как подписаться на тему в apache kafka из приложения java?

Это потребитель для Apache Kafka и он не получает сообщения из темы «тест» package com.kafka; import java.util.Arrays; import java.util.Properties; import org.apache.kafka.clients.consumer.Consum

0зной

1ответ

Kafka Spark-Streaming offset issue

Работа с Kafka Spark-Streaming. Возможность читать и обрабатывать данные, отправленные от Продюсера. У меня есть сценарий здесь, давайте предположим, что продюсер создает сообщения, а Consumer отключа

0зной

1ответ

Как разрешить зависимость org.apache.kafka.clients.producer.Producer в проекте maven как производитель java для apache kafka

Это контроллер для моего веб-приложения java. упаковка com.proj.controller; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping;