Commit graph

394 commits

Author SHA1 Message Date
Victor Alfaro
51646e786a
666: Adding new endpoint with corresponding service method. Also a… (#714)
* (#666): Adding new endpoint with corresponding service method. Also adding search box to kafka connect screen with consuming logic for added endopoint.

* Applying feedback: reusing same endpoint and removing '/filtered' version
2021-08-03 16:08:55 +03:00
Diego Ching
8a4df6b002 Enabling synonyms for TopicConfig 2021-08-02 12:24:42 -06:00
Diego Ching
b74a643c93 Adding new tests
Rebase from master, resolving conflicts
Adding new fields to builder
Removing unused import
2021-08-02 10:27:20 -06:00
Diego Ching
2a2e651d81 Adding new fields to TopicConfig
Adding tests for TopicConfigs consumer and service

Refactoring the tests

Fixing checkstyle violation
2021-08-02 08:32:06 -06:00
Roman Zabaluev
eed35de014
TLS enabled zookeeper (#722)
* Switch zk client. Resolves #683

* Add an example docker compose file with TLS enabled zookeeper

* Update readme a bit

* Fix annoying sonar boy

* Apply review suggestion

* Rename zookeeper ssl options
2021-07-30 17:56:32 +03:00
Marsel
f7ce347149
fix schemaRegistry property by adding checks (#752)
* fix schemaRegistry property by adding checks

* style fix

* pull request fix

Co-authored-by: marselakhmetov <makhmetov@provectus.com>
2021-07-30 15:51:56 +03:00
Timur Davletov
fa4ef337a7
#702 Supported incremental config update for brokers (#751) 2021-07-30 12:48:42 +03:00
Timur Davletov
2ab1601a7f
#708 Added log dirs alter operation (#723)
* #708 Added log dirs alter operation
2021-07-29 14:52:02 +03:00
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