我在 JUnit 測試中啟動了一個(gè) EmbeddedKafka 實(shí)例。我可以在應(yīng)用程序中正確讀取已推送到流的記錄，但我注意到的一件事是每個(gè)主題只有一個(gè)分區(qū)。誰能解釋為什么？在我的應(yīng)用程序中，我有以下內(nèi)容：List<PartitionInfo> partitionInfos = consumer.partitionsFor(topic);這將返回一個(gè)包含一項(xiàng)的列表。當(dāng)針對具有 3 個(gè)分區(qū)的本地 Kafka 運(yùn)行時(shí)，它會按預(yù)期返回包含 3 個(gè)項(xiàng)目的列表。我的測試看起來像：@RunWith(SpringRunner.class)@SpringBootTest@EmbeddedKafka(partitions = 3)@ActiveProfiles("inmemory")@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)@TestPropertySource(                locations = "classpath:application-test.properties",                properties = {"app.onlyMonitorIfDataUpdated=true"})public class MonitorRestKafkaIntegrationTest {    @Autowired    private EmbeddedKafkaBroker embeddedKafkaBroker;    @Value("${spring.embedded.kafka.brokers}")    private String embeddedBrokers;    @Autowired    private WebApplicationContext wac;    @Autowired    private JsonUtility jsonUtility;    private MockMvc mockMvc;    @Before    public void setup() {            mockMvc = webAppContextSetup(wac).build();            UserGroupInformation.setLoginUser(UserGroupInformation.createRemoteUser("dummyUser"));    }        private ResultActions interactiveMonitoringREST(String eggID, String monitoringParams) throws Exception {            return mockMvc.perform(post(String.format("/eggs/%s/interactive", eggID)).contentType(MediaType.APPLICATION_JSON_VALUE).content(monitoringParams));        }