Skip to content

Commit e04aeb5

Browse files
committed
test(be): partitionNumber 자료형 변경
- int -> String
1 parent b3bec81 commit e04aeb5

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/service

src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/service/KafkaProducer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,11 +24,11 @@ public class KafkaProducer {
2424

2525
public void sendChatMessage(ChatMessageToKafka chatMessageToKafka, Long channelId) {
2626
try {
27-
int partitionNumber = ThreadLocalRandom.current().nextInt(0, 3);
27+
String partitionNumber = String.valueOf(ThreadLocalRandom.current().nextInt(0, 3));
2828
String jsonChatMessage = objectMapper.writeValueAsString(chatMessageToKafka);
2929

3030
ProducerRecord<String, String> record =
31-
new ProducerRecord<>(topicChat, partitionNumber, null, jsonChatMessage);
31+
new ProducerRecord<>(topicChat, partitionNumber, jsonChatMessage);
3232

3333
kafkaTemplate.send(record)
3434
.whenComplete((result, ex) -> { //키 값 설정으로 순서 보장, 실시간성이 떨어짐, 고민해봐야 할 부분

0 commit comments

Comments
 (0)