X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Ftrion%2Fkafka%2Foutbox%2FUserRepository.java;h=3437051cc9fdd648403e8d504dd9facfeb870230;hb=900c3e78da3cc0bbf103c67f00243af1890826a9;hp=a12c2e739d3f9ca1a673dc2a0f0e831254b2468c;hpb=a498c7ae070b064dc7ea9a453b389ecff5c190ce;p=demos%2Fkafka%2Foutbox

diff --git a/src/main/java/de/trion/kafka/outbox/UserRepository.java b/src/main/java/de/trion/kafka/outbox/UserRepository.java
index a12c2e7..3437051 100644
--- a/src/main/java/de/trion/kafka/outbox/UserRepository.java
+++ b/src/main/java/de/trion/kafka/outbox/UserRepository.java
@@ -7,5 +7,5 @@ import org.springframework.jdbc.core.JdbcTemplate;
 
 public interface UserRepository extends CrudRepository<User, Long> {
     @Query("select * from User u where u.username = :username")
-    User findByEmailAddress(@Param("email") String username);
+    User findByUsername(@Param("username") String username);
 }