[
https://issues.apache.org/jira/browse/KAFKA-2576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14904601#comment-14904601
]
ASF GitHub Bot commented on KAFKA-2576:
---------------------------------------
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/236
KAFKA-2576; ConsumerPerformance hangs when SSL enabled for Multi-Partition
Topic
We now write to the channel with an empty buffer when
there are pending bytes remaining and all data has been
sent.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka-2576-ssl-multi-partition-topic-hang
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/236.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #236
----
commit b0cf6a8387473906de0ca4c05c4bb88eb8342b0f
Author: Ismael Juma <[email protected]>
Date: 2015-09-23T14:18:53Z
Fix infinite loop in `FetchResponse` `*Send` classes
We now write to the channel with an empty buffer when
there are pending bytes remaining and all data has been
sent.
----
> ConsumerPerformance hangs when SSL enabled for Multi-Partition Topic
> --------------------------------------------------------------------
>
> Key: KAFKA-2576
> URL: https://issues.apache.org/jira/browse/KAFKA-2576
> Project: Kafka
> Issue Type: Bug
> Reporter: Ben Stopford
> Assignee: Ismael Juma
> Priority: Blocker
> Fix For: 0.9.0.0
>
>
> Running the ConsumerPerformance using a multi partition topic causes it to
> hang (or execute with no results).
> bin/kafka-topics.sh --create --zookeeper server:2181 --replication-factor 1
> --partitions 50 --topic 50p
> bin/kafka-producer-perf-test.sh --broker-list server:9092 --topic 50p
> --new-producer --messages 1000000 --message-size 1000
> #Works ok
> bin/kafka-consumer-perf-test.sh --broker-list server:9092 --messages
> 1000000 --new-consumer --topic 50p
> #Hangs
> bin/kafka-consumer-perf-test.sh --broker-list server:9093 --messages
> 1000000 --new-consumer --topic 50p --consumer.config ssl.properties
> Running the same without SSL enabled works as expected.
> Running the same using a single partition topic works as expected.
> Tested locally and on EC2
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
