Commit aa0df97

committed

Remove throw

1 parent 1180717 commit aa0df97Copy full SHA for aa0df97

File tree

-4

lines changed

src/main/java/com/example/integrationtestspringkafka/service
- ConsumerService.java

-4

lines changed

Lines changed: 3 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -21,14 +21,13 @@ public class ConsumerService {`
`21`	`21`	`* Consume ExampleDTO on topic : TOPIC_EXAMPLE`
`22`	`22`	`* Then save it in database.`
`23`	`23`	`*`
`24`		`- * @param exampleDTO`
	`24`	`+ * @param exampleDTO {@link ExampleDTO}`
`25`	`25`	`*/`
`26`	`26`	`@KafkaListener(topics = "TOPIC_EXAMPLE", groupId = "consumer_example_dto")`
`27`		`- public void consumeExampleDTO(ExampleDTO exampleDTO) throwsException {`
	`27`	`+ public void consumeExampleDTO(ExampleDTO exampleDTO) {`
`28`	`28`	`log.info("Received from topic=TOPIC_EXAMPLE ExampleDTO={}", exampleDTO);`
`29`	`29`	`exampleRepository.save(convertToExampleEntity(exampleDTO));`
`30`		`- throw new Exception("cannot be done");`
`31`		`- // log.info("saved in database {}", exampleDTO);`
	`30`	`+ log.info("saved in database {}", exampleDTO);`
`32`	`31`	`}`
`33`	`32`
`34`	`33`	`/**`

Comments

(0)