"chat.backend.kafka.client-id-PREFIX=TEST",
"chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
"spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
- "chat.backend.kafka.chatrooms-topic=" + CHATROOMS_TOPIC,
- "chat.backend.kafka.messages-topic=" + MESSAGES_TOPIC,
+ "chat.backend.kafka.chatroom-channel-topic=" + CHATROOMS_TOPIC,
+ "chat.backend.kafka.message-channel-topic=" + MESSAGES_TOPIC,
"chat.backend.kafka.num-partitions=3" })
@EmbeddedKafka(topics = { CHATROOMS_TOPIC, MESSAGES_TOPIC }, partitions = 3)
class KafkaConfigurationIT extends AbstractConfigurationIT
{
- final static String CHATROOMS_TOPIC = "TEST_CHAT_ROOMS";
- final static String MESSAGES_TOPIC = "TEST_CHAT_MESSAGES";
+ final static String CHATROOMS_TOPIC = "TEST_CHATROOM_CHANNEL";
+ final static String MESSAGES_TOPIC = "TEST_MESSAGE_CHANNEL";
@BeforeAll
public static void test(