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

336 commits

Author SHA1 Message Date
Marsel
699512f706
Issue#701 brokers config (#730) 
* adding getBrokerConfigs endpoint

* adding tests

Co-authored-by: marselakhmetov <makhmetov@provectus.com>
 2021-07-29 13:50:44 +03:00
Timur Davletov
d29f42e0a0
Fix for randomly failing tests (null in KafkaCluster.getTopics()) (#728) 2021-07-29 08:44:37 +03:00
Ilnur Farukhshin
693cd475f3
Merge pull request #682 from provectus/issue207/ksqldb 
Add KSQL DB support
 2021-07-27 15:16:25 +03:00
Timur Davletov
29a3158df6
#707 Exposed broker log dirs (#720) 
#707 Exposed broker log dirs
 2021-07-27 13:03:21 +03:00
Ilnur Farukhshin
3bf5a08d3a Merge branch 'master' into issue207/ksqldb 2021-07-26 13:55:25 +03:00
Ilnur Farukhshin
64e2caf55c [#207]: PR feedback 2021-07-26 13:52:38 +03:00
Marsel
20cbcd33e2
Issue#493 add authentication to schema registry (#679) 
* adding basic authentication for SchemaRegistry

* checkstyle fix

* tests fix

* pull request fix

* pull request fixes

* replace string with constant

* adding documentation

Co-authored-by: marselakhmetov <makhmetov@provectus.com>
 2021-07-23 18:52:15 +03:00
Ilnur Farukhshin
232a17b80d [#207]: fix(api): clean up 2021-07-23 16:32:45 +03:00
Ilnur Farukhshin
82ce538488 [#207] fix(api): lint 2021-07-23 13:15:34 +03:00
Ilnur Farukhshin
c784fc87c4 [#207] fix(api): lint import 2021-07-23 13:04:01 +03:00
Ilnur Farukhshin
0434c48a2d [#207] fix(api): lint 2021-07-23 12:49:11 +03:00
Ilnur Farukhshin
d59b4e69f9 [#207] tests(api): added unit tests for KsqlService, KsqlCommandStrategies 2021-07-23 10:07:54 +03:00
Roman Zabaluev
b296108e5b
Forward schema registry errors to API (#693) 
* Forward schema registry errors to API

* Fix pr checks job
 2021-07-21 15:54:31 +03:00
Ilnur Farukhshin
61289dde61 [#207] feat(api): add ksql_db feature, expection handler to ksql client 2021-07-20 17:03:10 +03:00
Ilnur Farukhshin
fb68d19802 [#207] feat(api, contract): added strategies for statements, return message or data with datble as response 2021-07-20 15:39:34 +03:00
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