Skip to content

Commit 23b08ca

Browse files
authored
Formatting changes and bumped up the release version. (#4)
1 parent 27074de commit 23b08ca

File tree

6 files changed

+14
-6
lines changed

6 files changed

+14
-6
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434

3535
To run Tansen for Apache Kafka, you can use either a pre-built Docker image or build it (or a jar file) yourself. For running with Docker you can use this command.
3636
```shell
37-
docker run -d -p 8080:8080
37+
docker run -d -p 8080:8080
3838
-e 'TANSEN.KAFKA-CLUSTERS.0.BOOTSTRAP_SERVERS=broker:9092' \
3939
-e 'TANSEN.KAFKA-CLUSTERS.0.NAME=local' \
4040
ideasbucket/tansen:tag

backend/main/java/com/ideasbucket/tansen/entity/MessageSelectionCriteria.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
import com.fasterxml.jackson.annotation.*;
1010
import jakarta.validation.constraints.Min;
1111
import jakarta.validation.constraints.NotNull;
12-
1312
import java.time.Instant;
1413

1514
@JsonInclude(JsonInclude.Include.NON_NULL)

backend/main/kotlin/com/ideasbucket/tansen/controller/api/MessagesController.kt

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,9 @@ import java.time.Duration
4747
import java.util.*
4848

4949
@RestController
50-
@RequestMapping("api/{clusterId:[a-zA-Z0-9][a-zA-Z0-9\\_\\-]+}/messages/{keySerde:auto|string}/{valueSerde:auto|string}")
50+
@RequestMapping(
51+
"api/{clusterId:[a-zA-Z0-9][a-zA-Z0-9\\_\\-]+}/messages/{keySerde:auto|string}/{valueSerde:auto|string}"
52+
)
5153
@Validated
5254
class MessagesController(
5355
private val clusterService: ClusterService,
@@ -64,7 +66,9 @@ class MessagesController(
6466
@PathVariable topic: String,
6567
@PathVariable keySerde: String,
6668
@PathVariable valueSerde: String,
67-
@Valid @RequestParam(name = "parameters", required = false) criteria: MessageSelectionCriteria?
69+
@Valid
70+
@RequestParam(name = "parameters", required = false)
71+
criteria: MessageSelectionCriteria?
6872
): Flow<ObjectNode> {
6973
val topicInformation =
7074
topicService.getTopic(clusterId, topic)

backend/main/kotlin/com/ideasbucket/tansen/controller/api/SubjectController.kt

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,6 @@
77
package com.ideasbucket.tansen.controller.api
88

99
import com.fasterxml.jackson.databind.JsonNode
10-
import com.ideasbucket.tansen.entity.MessageSelectionCriteria
1110
import com.ideasbucket.tansen.entity.Response
1211
import com.ideasbucket.tansen.entity.SaveSchemaRequest
1312
import com.ideasbucket.tansen.entity.TopicSchema

frontend/src/util/StreamLogicError.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,9 @@
1+
/*
2+
* This file is part of the Tansen project.
3+
*
4+
* For the full copyright and license information, please view the LICENSE
5+
* file that was distributed with this source code.
6+
*/
17
export class StreamLogicError extends Error {
28
constructor(message: string) {
39
super(message)

gradle.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
version = 0.7.1
1+
version = 0.8.1

0 commit comments

Comments
 (0)