Skip to content

Commit 467d423

Browse files
committed
Minor clean up
1 parent 442b5e3 commit 467d423

File tree

4 files changed

+3
-67
lines changed

4 files changed

+3
-67
lines changed

src/main/java/com/madadipouya/springkafkatest/consumer/UserKafkaListener.java

Lines changed: 0 additions & 26 deletions
This file was deleted.

src/main/java/com/madadipouya/springkafkatest/controller/UserController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.github.javafaker.Faker;
44
import com.madadipouya.springkafkatest.dto.User;
5-
import com.madadipouya.springkafkatest.producer.UserKafkaProducer;
5+
import com.madadipouya.springkafkatest.kafka.producer.UserKafkaProducer;
66
import io.swagger.annotations.Api;
77
import io.swagger.annotations.ApiOperation;
88
import org.springframework.http.HttpStatus;
@@ -29,7 +29,7 @@ public UserController(UserKafkaProducer kafkaProducer) {
2929

3030
@GetMapping("/random")
3131
@ResponseStatus(HttpStatus.OK)
32-
@ApiOperation(value = "Creates a random user and write it to Kakfa which is consumed by the listener")
32+
@ApiOperation(value = "Creates a random user and write it to Kafka which is consumed by the listener")
3333
public void generateRandomUser() {
3434
kafkaProducer.writeToKafka(new User(UUID.randomUUID().toString(), faker.name().firstName(), faker.name().lastName()));
3535
}

src/main/java/com/madadipouya/springkafkatest/dto/User.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ public class User {
88

99
private String lastName;
1010

11-
private User() {
11+
public User() {
1212

1313
}
1414

src/main/java/com/madadipouya/springkafkatest/producer/UserKafkaProducer.java

Lines changed: 0 additions & 38 deletions
This file was deleted.

0 commit comments

Comments
 (0)