apache-kafka

0зной

1ответ

Как изменить __consumer_offsets очистка plicy для удаления из компактного?

Я Кафка кластеры с 3-мя узлами, в каталоге журнала Кафка имеют __consumer_offsets-XX, много файлов журналов, как 100MB, используемого дискового места более чем на 90%, команда excutes: ./bin/kafka-con

1зной

1ответ

Kafka streams - объединение двух ktables вызывает функцию соединения дважды

Я пытаюсь присоединиться к 2 KTables. KTable<String, RecordBean> recordsTable = builder.table(Serdes.String(), new JsonPOJOSerde<>(RecordBean.class), bidTopic, RECORDS_STORE); KTable<Strin

1зной

2ответ

Каков прецедент для установки коэффициента репликации Kafka в 0?

Устанавливает коэффициент репликации 0 недействительным для производственной среды или существует прецедент, где это имеет смысл?

3зной

1ответ

Признайте в @ KafkaListener-метод без «потери» сообщений

мы в настоящее время признающих сообщения в основном со следующим упрощенным механизмом: @KafkaListener(topics = "someTopic") public void listen(final String message, final Acknowledgment ack) {

0зной

2ответ

Kafka используется как механизм доставки в ленте новостей

Могу ли я создавать темы под названием update_i для различных видов обновлений и разбивать их на user_id в Kafka MQ? Я прошел через этот пост confluent.io: https://www.confluent.io/blog/how-to-choose-