producer-consumer

0зной

1ответ

не consumer.poll выборка записей из Кафки Темы с 3 разделами

Примечания: Кафка версия используется: kafka_2.11-0.9.0.1 У меня есть одна тема с именем test-kafka, который, как и 3 partitions1 replication factor и этой тема имеют некоторые строковые данные, т.е.

0зной

1ответ

Как отправить сообщения на эту тему с помощью производителя kafka?

У меня есть клиент kafka, который производит и потребляет сообщения, он работает как ожидалось, когда мы отправляем полезную нагрузку от продюсера на тему, поэтому у меня проблема с производителем, те

1зной

1ответ

смещения и задержки для Кафки потребителя (созданный с помощью нового потребительского API) установлены в неизвестном

Я часто видя проблему, в котором Кафка потребитель получает текущее смещение и лаг установлен неизвестный Ранее потребитель имел смещение и лаг GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET,

13зной

2ответ

Ошибка: не удалось найти или загрузить основной класс config.zookeeper.properties

Я пытаюсь выполнить примерное потребительское приложение производителя с помощью Apache Kafka. Я загрузил его с https://www.apache.org/dyn/closer.cgi?path=/kafka/0.10.0.0/kafka-0.10.0.0-src.tgz. Затем

0зной

1ответ

Почему Pascal FC не хочет запускать этот код с мониторами?

Я программирую параллелизм в Pascal-FC, используя Eclipse Gavab 2.0. До сих пор у меня не было никаких проблем, так как он всегда сообщал мне, какие ошибки возникают, когда он не может выполнить прогр

2зной

1ответ

Эффективность выполнения нескольких производителей-потребителей

Я пытался создать код с несколькими производителями и потребителями. Я создал несколько потоков для производителя и потребителя и использовал семафоры для синхронизации. Код работал отлично с одним пр