* Map schema registry port to 8081 in kafka-clusters-only.yaml
* Add endpoint to retrieve subjects from schema registry by cluster name
* Add endpoint to retrieve subject versions from schema registry
* Get subject schema by version from schema-registry
* Add ability to create/delete schema subjects in/from schema-registry service
* Create WebClient bean and refactor its usage
* Refactor schema api contract
* Return 'Bad request' if there is 'Internal Server Error' from Schema Registry
* Add GET/PUT methods to get/update a schema compatibility level globally or only for a scepific schema
* Add SchemaRegistryContainer.java and testcontainers dependencies for integration tests
* Add junit-jupiter5 for testing
* Add GET/DELETE actions for the latest schema version
* Add endpoint to check schema compatibility
* Set up configuration for testing
* Add basic test for SchemaRegistryService
* Fix mapping from dto to web model
* Change createNewSchema action's endpoint
* Update tests in SchemaRegistryServiceTests
* Rename getLatestSchema method and update tests
* Add more test in SchemaRegistryServiceTests
* Include compatibility level info to schema response. Change Flux to Mono
* Update tests
* Pass schema-registry url for secondLocal cluster too
* Remove explicit returns of 404 status code (it'll be processed by global error handler)
* Add global error handler to response with exception details
* Autoconfigure WebTestClient in SchemaRegistryServiceTest
* Added message sending
* sent message to kafka
* renamed docker service
* renamed message file
* Changed message to json
* fixed docker compose and messages
Co-authored-by: Roman Nedzvetskiy <roman@Romans-MacBook-Pro.local>
Co-authored-by: German Osin <german.osin@gmail.com>
* Start doing endpoint for jmx metrics
* Added endpoint for getting jmx metric per broker
* Cluster jmx metrics sum endpoit added
* Added endpoints for cluster metrics and broker metrics
* Cleared some code
* Fixed jmxmetrics names
* Changed to all values in metrics
* Removed redundant imports
* Renamed param constant
* Changed to calculate brokers and clusters metrics in one place
* Removed redundant imports
* Fixed some mistakes
* Replaced multiple method usage into single
* Fixed mulptiple call
* Removed cluster level metrics, now only broker-level metrics in cluster
* Just small fixes
* removed redundant variable
* Renamed method for cluster level metrics
* Fixed after PR and added sum for number cluster metrics by num and persec keywords in canonicalname
* Added metricdto object
* Added list of metrics to enum
* Renames and optimizings
* Renamed jmxmetrics objects param to metrics
Co-authored-by: Roman Nedzvetskiy <roman@Romans-MacBook-Pro.local>
* Added begin and end offset param
* moved consumer to try with resources block
* Fixed some problems
* Moved to gettopicdetails
* Cleanup code
Co-authored-by: Roman Nedzvetskiy <roman@Romans-MacBook-Pro.local>
Co-authored-by: German Osin <german.osin@gmail.com>
* Added segmentSize for topic level
* Added segmentSize to clusterMetrics object
* Added internalClusterState for storing clusterMetrics linked to cluster's brokersIds
* InternalBrokersMetrics param added to InternalClusterMetrics
* Changed topic segment counting logic by finding the partition leader, added partition collecting in topic
* Added segmentSize info to cluster, broker, topic and topicPartition level
* Reduce to map moved to clusterutil, leader moved in cache
* Cleared some code
Co-authored-by: Roman Nedzvetskiy <roman@Romans-MacBook-Pro.local>
