apache-kafka

0зной

2ответ

Возможные варианты использования для kafka/storm/spark на веб-сайте B2C

У моей компании есть веб-сайт B2C, который обслуживает несколько тысяч пользователей сети в день. Он использует PHP, angular.js и MySQL. Мы хотели бы перейти в новые технологические области, и мы увид

1зной

1ответ

Какой API-интерфейс на Kafka Client позволит сбросить смещение до последнего совершенного?

Я использую версию Java версии клиента Kafka версии 0.10.0.0. В моем случае автоматическая фиксация отключена, и мы читаем ее с помощью KafKaClient.poll (timout) api. Мы обрабатываем все сообщения, и

2зной

1ответ

KafkaStreams - InconsistentGroupProtocolException

У меня есть приложение Кафка Streams, который подключается к нашему кластеру Кафки, используя Кафка Streams DSL, например, так: KStreamBuilder builder = new KStreamBuilder(); KStream<String, byte[]>

0зной

1ответ

получить тему и раздел смещения

Исключение в потоке "основного" java.nio.channels.ClosedChannelException на kafka.network.BlockingChannel.send (BlockingChannel.scala: 100) в kafka.consumer.SimpleConsumer.liftedTree1 $ 1 (SimpleConsu