1 В избранное 0 Ответвления 0

OSCHINA-MIRROR/myself_opensource-new-kafka-eagle

Присоединиться к Gitlife
Откройте для себя и примите участие в публичных проектах с открытым исходным кодом с участием более 10 миллионов разработчиков. Приватные репозитории также полностью бесплатны :)
Присоединиться бесплатно
Клонировать/Скачать
Внести вклад в разработку кода
Синхронизировать код
Отмена
Подсказка: Поскольку Git не поддерживает пустые директории, создание директории приведёт к созданию пустого файла .keep.
Loading...
README.md

Данный проект основан на открытом проекте kafka-eagle и был модифицирован в соответствии с личными интересами.

Изменения:

  • springmvc заменён на springboot;
  • безопасность заменена на spring security;
  • ресурсы kafka используют пул apache commons;
  • интерфейс Thymeleaf был переработан;
  • добавлен скрипт запуска кластера Zookeeper start-zookeeper-cluster.sh для удобства тестирования;
  • добавлен скрипт запуска Kafka-кластера start-kafka-cluster.sh (по умолчанию включает JMX-функционал для удобства мониторинга), для удобства тестирования;
  • шаблоны KafkaZkClient, AdminClient, KafkaConsumer, KafkaProducer и JMXConnector были переработаны для упрощения управления ресурсами.

Ожидаемые результаты:

  • отделение логики бэкенда от фронтенда, полный контроль отображения на странице;
  • добавление функции обновления сообщений в темах Kafka в реальном времени;
  • полная поддержка уведомлений по электронной почте;
  • конфигурируемость платформы кластера.

Инструменты Kafka:

Создание темы: kafka-topics.sh --create --bootstrap-server debian:9091,debian:9092,debian:9093 --replication-factor 1 --partitions 1 --topic SAMPLE
Список тем: kafka-topics.sh --list --bootstrap-server debian:9091,debian:9092,debian:9093
Отправка сообщения: kafka-console-producer.sh --bootstrap-server debian:9091,debian:9092,debian:9093 --topic SAMPLE
Получение сообщения: kafka-console-consumer.sh --bootstrap-server debian:9091,debian:9092,debian:9093 --topic SAMPLE --from-beginning

Тестирование производительности отправки сообщений: kafka-producer-perf-test.sh --topic SAMPLE --num-records 10000000 --record-size 100 --throughput 5000 --producer-props bootstrap.servers=debian:9091,debian:9092,debian:9093
Тестирование производительности получения сообщений: kafka-consumer-perf-test.sh --broker-list debian:9091,debian:9092,debian:9093 --topic SAMPLE --fetch-size 1048576 --messages 10000000 --threads 1

Запуск приложения:

## Примечание: раскомментируйте строки, чтобы приложение автоматически создало таблицы и импортировало начальные данные, по умолчанию логин: admin/admin
spring.datasource.schema=classpath:sql/schema.sql
spring.datasource.data=classpath:sql/data.sql

Комментарии ( 0 )

Вы можете оставить комментарий после Вход в систему

Введение

Система управления Kafka, основанная на модификации открытого исходного кода проекта kafka-eagle. Развернуть Свернуть
Java и 5 других языков
Apache-2.0
Отмена

Обновления

Пока нет обновлений

Участники

все

Недавние действия

Загрузить больше
Больше нет результатов для загрузки
1
https://api.gitlife.ru/oschina-mirror/myself_opensource-new-kafka-eagle.git
git@api.gitlife.ru:oschina-mirror/myself_opensource-new-kafka-eagle.git
oschina-mirror
myself_opensource-new-kafka-eagle
myself_opensource-new-kafka-eagle
develop