0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
1439 commits 52 branches 38 tags 1.9 GiB
Commit graph

321 commits

Author SHA1 Message Date
Marsel
cac9069774
Issue#634 clean up policy in topic list (#665) 
* adding cleanup policy to InternalTopic

* adding CleanupPolicy enum

Co-authored-by: marselakhmetov <makhmetov@provectus.com>
 2021-07-20 11:57:13 +03:00
German Osin
32a0ece0a3
Added AWS IAM (#692) 2021-07-20 11:55:24 +03:00
Ilnur Farukhshin
3686e75c8f [#207] feat(api, contract): return ksql command result as table 2021-07-19 17:21:23 +03:00
Ilnur Farukhshin
bd9f8280e8 [#207] fix(api): clean up 2021-07-15 15:18:33 +03:00
Ilnur Farukhshin
3d5bbc854a [issue207] feat(api, contract): ksqldb controller, client, service, statement strategies 2021-07-15 15:05:34 +03:00
Ildar Almakaev
5f4de1313d
Handle errors when creating topics and return custom one as BAD_REQUEST (#670) 2021-07-14 15:35:45 +03:00
Roman Zabaluev
9b6952c480
Implements #610 (#673) 2021-07-14 11:08:42 +03:00
Ilya Kuramshin
73d4e48941
Json Schema support (#651) 
* Json schema support implementation

* comments & checkstyle

* unused mapper removed

* Explicit validation added

Co-authored-by: Ilya Kuramshin <ikuramshin@provectus.com>
 2021-07-12 13:41:38 +03:00
German Osin
13463fe95f
Refactor consumer groups requests (#636) 
* Refactor consumer groups requests

* Fixed offsets tests

* Moved state enum to separate class

* Adjust frontend for the new API

Co-authored-by: Alexander <mr.afigitelniychuvak@gmail.com>
 2021-07-09 15:55:43 +03:00
Ilya Kuramshin
dd19cc2eec
Msg sending improvements (#640) 
* init

* Messages sending fixes & tests

* Messages sending fixes & tests

* Messages sending json test added

* PR comments fixes

* Setting getTopicMessages & sendTopicMessage key value type to string.

* admin-client-timeout default removed

* sonar fix

* messages filtering changes to String.contains

Co-authored-by: Ilya Kuramshin <ikuramshin@provectus.com>
 2021-07-09 15:53:30 +03:00
German Osin
71e1370deb
Provide topic offsets in list (#647) 2021-07-07 22:31:45 +03:00
Marsel
df1d3bbfc7
adding sorting parameter (#646) 
Co-authored-by: marselakhmetov <makhmetov@provectus.com>
 2021-07-07 18:50:27 +03:00
Marsel
0ec40dd7e4
Issue#314 replication factor change (#599) 
* adding replication factor change feature

* adding comments for algorithm and some fixes

* small fix

* checkstyle fixes

* fix

* adding updateCluster endpoint and algorithm fixes

* hot fixes

* update algorithm and add brokers list to KafkaCluster

* pull request fix

Co-authored-by: marselakhmetov <makhmetov@provectus.com>
 2021-07-07 17:59:52 +03:00
Ilya Kuramshin
66228b00d5
#234: Consumer group offsets reset implementation (#605) 
* junit4 annotations replaced with jupiter

* Consumer group offsets reset implementation

* comments added, Sonar warn fix

* minor cleanup

* checkstyle fix

* PR comments fix

* API doc fix

* API path renamed

Co-authored-by: Ilya Kuramshin <ikuramshin@provectus.com>
 2021-07-05 14:32:01 +03:00
German Osin
e3b2ea1052
Added cluster version to api (#609) 2021-07-02 15:33:52 +03:00
German Osin
ca476d3373
#122 Fixed compacted topics backward reading (#607) 2021-07-02 14:52:40 +03:00
Marsel
09ebd03e71
Issue#314 partitions count increase (#579) 
* adding topic's partitions count increase

* adding tests

* making pull request fixes

* making pull request fixes

* adding checkstyle fix

* pull request fixes

* adding cluster update after increasing partitions

* pull requset fix

Co-authored-by: marselakhmetov <makhmetov@provectus.com>
 2021-07-02 14:38:22 +03:00
German Osin
3fa2b995c6
#122 Fixed npe in backward emitter (#601) 2021-06-29 19:00:31 +03:00
German Osin
97ec512b00
#122 Fix emitter to consume records in right order (#598) 
* #122 Fix emitter to consume records in right order

* Fixed naming
 2021-06-29 09:52:18 +03:00
German Osin
1460fef68e
ISSUE-502 Send messages & avro key deserializer (#582) 
* ISSUE-502 Send messages & avro key deserializer

* Fixed sonarcube issue

* Fixed sonarcube issues

* Schema endpoint & fixes

* fixed sonar issue
 2021-06-28 09:54:20 +03:00
German Osin
1a916ab247
#581 Skip trailing slash (#586) 2021-06-25 15:39:07 +03:00
Ildar Almakaev
5dd3944faa
Add API to delete consumer group by id (#578) 
* [issue-516] Add API to delete consumer groups by IDs

* Add more tests to check consumer groups deletions

* Refactor and fix code style

* Fix codestyle

* Rethrow OperationInterruptedException with 500 error code if a thread is interrupted

* Use SneakyTrhrows to handle InterruptedException. Refactor

* Change deletion of groups API to single group delete

* Fix codestyle

* Rollback changes in kafka-ui-react-app/package-lock.json
 2021-06-23 20:47:32 +03:00
German Osin
de5a8652a1
#122 Added messages reording (#577) 2021-06-22 16:06:03 +03:00
German Osin
d3bf65cfb6
#122 Seek direction backend support (#562) 2021-06-18 11:56:14 +03:00
github-actions
081695d5e6 Increased version in pom.xml 2021-06-09 11:37:21 +00:00
github-actions
54581bee63 Increased release 2021-06-09 11:37:18 +00:00
German Osin
723d552c23
Update StaticController.java 
Fixed basepath replacer
 2021-06-08 14:19:35 +03:00
German Osin
a1ee6a30c0
#518 Fixed backend page size (#523) 
* #518 Fixed backend page size

* Fixedd tests
 2021-06-03 19:44:42 +03:00
Rustam Gimadiev
fcc703ddd6
Add ability to use custom basePath (#511) 
* add ability to use relative pathes

* Add basename prop (#513)

* add static controller

* add docker-compose

* Refactoring

* Refactoring

* fixed comparison bugs

* dirty

* clenaup

* Update React app

Co-authored-by: Alexander Krivonosov <31561808+GneyHabub@users.noreply.github.com>
Co-authored-by: German Osin <german.osin@gmail.com>
Co-authored-by: Oleg Shuralev <workshur@gmail.com>
 2021-06-03 15:46:13 +03:00
Ildar Almakaev
721cf0e750
[Kafka Connect] Fix getting list of connector's topics (#504) 
* [Kafka Connect] Fix getting list of connector's topics

* Fix code style in KafkaConnectService.java

* Fix code style
 2021-05-31 12:30:29 +03:00
Jakub Štiller
69c034c793
Do not try to connect to zookeeper if connection string is empty (#428) 
Co-authored-by: Jakub Štiller <stiller@2n.cz>
 2021-05-13 10:11:38 +03:00
Marat Adiyatullin
a0b78f68df Merge master 2021-05-12 14:37:46 +03:00
Jakub Štiller
f156302c47 Remove default cluster configuration. 
When this default cluster configuration is setup, user have to override complete first cluster. Eg have to set KAFKA_CLUSTERS_0_ZOOKEEPER to empty string to override default localhost.
 2021-05-11 14:17:47 +03:00
German Osin
a427a55c30
ISSUE-408 Mark underscored topics as internal (#430) 
* ISSUE-408 Mark underscored topics as internal

* ISSUE-408 Mark underscored topics as internal
 2021-05-07 18:06:02 +03:00
Jakub Štiller
632bcd20e9 Use spring oauth2 starter as dependency to be able use various oauth2 providers. 2021-05-07 17:14:11 +03:00
Marat Adiyatullin
16e63f2c35 Add connect views 2021-05-03 13:33:53 +03:00
Ramazan Yapparov
f3c0866940
#187 added search and sorting (#388) 
* - added search by topic name
- added filter by internal topics
- added sort by multiple columns
- added tests

* moved sorting later in the stream
 2021-04-27 13:32:08 +03:00
Ramazan Yapparov
eef45fc6ab
#356 added endpoint to fetch all cluster connectors (#361) 
* added endpoint to fetch all cluster connectors

* - refactoring code
- refactoring schema
- added connector class property
 2021-04-15 11:15:25 +03:00
German Osin
7bfae45162
ISSUE-121 Topic level consumer groups & consumerr group details (#360) 2021-04-08 11:49:44 +03:00
Rustam Gimadiev
7bc01811c3
Display info about app version (#335) 
* inject VERSION to npm build

* [issues#315] add new component VersionApp. Display application version in UI

* [CHORE] Adds info about app vesrsion

* fix mvn envs

* [CHORE] Cleanup and specs

Co-authored-by: mbovtryuk <mbovtryuk@provectus.com>
Co-authored-by: Oleg Shuralev <workshur@gmail.com>
 2021-04-05 13:44:08 +03:00
Ildar Almakaev
e9a0a1af91
Get only numeric values of JMX metrics (#318) 
* Use only numeric JMX metrics
* Propagate all exceptions from JmxClusterUtil.getJmxMetric to upper call
 2021-03-31 12:34:43 +03:00
iliax
21a090f102
No such schema message formating fix (#316) 
Co-authored-by: Ilya Kuramshin <ikuramshin@provectus.com>
 2021-03-25 14:15:34 +03:00
iliax
8d2f929a52
ISSUE-309: Topic create & update models split (#312) 
* ISSUE-309: Topic create & update models split
 2021-03-25 11:24:51 +03:00
iliax
31fe89d1c9
ISSUE-297: Sonar warnings fixes (#298) 
* ISSUE-297: Sonar warnings fixes
 2021-03-23 21:54:03 +03:00
iliax
106c42e4cc
ISSUE-257: ErrorResponse format description (#294) 
* ISSUE-257: ErrorResponse format description & processing added
 2021-03-23 16:44:57 +03:00
iliax
992e8b0898
#253: Get messages implementation improvement (#286) 
* 1. End offsets check added to RecordEmitter
2. Tests for OffsetsSeek, RecordEmitter added

* Tests improvements

* ISSUE-257: checkstyle

* ISSUE-257: withSchemaType sonar fix

* ISSUE-257: withSchemaType sonar fix

Co-authored-by: Ilya Kuramshin <ikuramshin@provectus.com>
 2021-03-23 14:55:04 +03:00
German Osin
590bdfb610
Added checkstyle (#296) 2021-03-23 10:55:28 +03:00
Ramazan Yapparov
217b363076
added features field to kafka cluster (#256) 2021-03-18 21:16:59 +03:00
Ramazan Yapparov
a8ed4ff37f
#188 added pagination for get topics api (#249) 
* added pagination for get topics api

* frontend fix

* - fixed merge conflicts
- renamed pageSize to perPage
 2021-03-15 21:37:36 +03:00
German Osin
909e196011
Feature refactoring, structure simplifying (#250) 2021-03-15 17:41:25 +03:00