春季雲流 - 卡夫卡粘合劑性能

Question

，我有以下簡單的代碼：

private int i = 0; 

    @StreamListener(Sink.INPUT) 
    public void processMessage(Message<?> message) { 
     i++; 
    } 

    @Scheduled(fixedDelay=5000) 
    private void scheduled(){ 
     LOG.info("Messages consumed: " + i); 
    } 

及以下屬性：

spring.cloud.stream.bindings.input.consumer.headerMode=raw 
spring.cloud.stream.kafka.binder.autoCreateTopics=false 
spring.cloud.stream.kafka.bindings.input.consumer.autoCommitOffset=false 
spring.cloud.stream.bindings.input.destination=test6 
spring.cloud.stream.bindings.input.group=testGroup50 
spring.cloud.stream.bindings.input.partitioned=false 

我與單個分區的本地卡夫卡話題96 k條消息。 由卡夫卡庫提供的簡單卡夫卡消費者在大約4秒消耗這些消息。

但是，上面的代碼接近1分鐘！

很顯然，這是對我們的應用關注的問題，有沒有人經歷過這個？我在這裏錯過了什麼嗎？

可視VM不會標記任何東西。

PS：我只是嘗試過自動提交，我仍然看到一個殘酷的表現。

Answer 1

由於@Marius Bogoevici的研究，人們發現業績不佳是造成的Mac OS：

https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/71#issuecomment-263280685

發佈本作的情況下，任何人都遇到這個問題的參考。

Answer 2

我認爲最好是在https://github.com/spring-cloud/spring-cloud-stream-binder-kafka中打開Git Hub問題。

此外，您可以指出您使用的是哪個版本，請問您的郵件大小是多少，以便我們可以重複測量？謝謝。

編輯：依照討論https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/71，這似乎是特定於MacOS的（到目前爲止轉載塞拉利昂和埃爾卡皮坦）和0.9客戶端）