Предполагая, что у меня есть несколько тем с одинаковым префиксом, например: giorgos-topic1 giorgos-topic2 giorgos-topic3 ... Команда, используемая для удаления одной темы (например, giorgos-topic1 ), выглядит следующим образом:...

У меня есть кластер Kafka из 3 узлов с 1 ZK и 1 брокером на каждом. Kafka version 0.10.1.1. В каждой теме есть replication-factor=3 и min.insync.replicas=2 . После этого мы проверили, отправив --describe , что темы были успешно созданы с...

Поэтому, когда я ищу способ подсчета сообщений в теме, этот вариант хорош. kafka-run-class kafka.tools.GetOffsetShell --broker-list broker1:9092,broker2:9092,broker3:9092 --topic rev-dly-upd --time -1 Единственное, когда я меняю конфиг...

Я работаю с ksql довольно давно. Кластер Kafka если из 3 узлов. Я тоже использовал udf, и все выглядит хорошо, пока я не остановлю серверы и не запустил их снова. При запуске сервера я вижу в журналах следующее: [2019-04-03 11:29:54,381] ERROR...

Я начинаю работать с Kafka и довольно новичок в Python. Я использую эту библиотеку с именем kafka-python для связи с моим Kafka. маклер. Теперь мне нужно динамически создать тему из моего кода, из документов я вижу, что я могу вызвать метод...

Я пытаюсь прочитать данные из темы kafka, используя потоковую передачу искры. Я могу создать сообщение в теме kafka, но при чтении данных из темы с использованием потоковой передачи искры я получаю сообщение об ошибке, как показано ниже: ERROR...

Я пытаюсь создать исходное соединение Kafka с режимом отметки времени в Windows. У меня есть эта таблица: CREATE TABLE "usu"."mytable" ( "first_name" CHAR(8 BYTE) DEFAULT ' ', "last_name" CHAR(8 BYTE) DEFAULT ' ', "regist" TIMESTAMP (0)...

Привет, я работаю над кафкой. Я пытаюсь понять основы кафки. Я сейчас учу кафку. Я установил кафку с помощью докера. На данный момент у меня один брокер. Я создал тему с 3 разделами, используя команду ниже. kafka-topics --create --zookeeper...

Я написал тестовый класс для приложения потока kafka согласно https://kafka.apache.org/24/documentation/streams/developer-guide/testing.html , код которого import com.EventSerde; import org.apache.kafka.common.serialization.Serde; import...

Я использую структурированную потоковую передачу искры, чтобы получать данные из темы кафки и записывать данные в другой приемник кафки. Я хочу сохранить смещение дважды - один раз при чтении из темы и пошевелить смещение. Во-вторых, при записи...

У меня есть поток, в котором из мэйнфрейма IBM IIDR я отправляю записи в тему Kafka. value_format сообщения, приходящего в тему Kafka, - это AVRO, и ключ также в формате AVRO. Записи пихаются в тему Кафки. У меня есть поток, связанный с этой...

Я хотел бы задать вам несколько вопросов по apache kafka и сжатым темам. Мы хотим предоставить некоторые данные PII по сжатой теме kafka. Мы хотим удалить данные по этой теме через надгробие. В настоящее время есть несколько вопросов, по которым мы...

Я использую брокер Kafka (версия 2.12) с настройками сервера по умолчанию на моем Mac. Я создал сжатую тему журнала со следующей конфигурацией - Configs: cleanup.policy=compact,segment.bytes=1073741824,delete.retention.ms=100,segment.ms=100 Я...

Есть ли способ создать тему kafka в файлах конфигурации kafka / zookeeper до , когда я буду запускать службы, поэтому как только они начнутся - темы будут на своих местах? Я заглянул внутрь скрипта bin/kafka-topics.sh и обнаружил, что в конце...