[jira] [Commented] (KAFKA-3121) KStream DSL API Improvement

[ https://issues.apache.org/jira/browse/KAFKA-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124460#comment-15124460 ] ASF GitHub Bot commented on KAFKA-3121: --- GitHub user guozhangwang opened a pull request:

[jira] [Commented] (KAFKA-2607) Review `Time` interface and its usage

[ https://issues.apache.org/jira/browse/KAFKA-2607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124297#comment-15124297 ] ASF GitHub Bot commented on KAFKA-2607: --- GitHub user afine opened a pull request:

[jira] [Commented] (KAFKA-3179) Kafka consumer delivers message whose offset is earlier than sought offset.

[ https://issues.apache.org/jira/browse/KAFKA-3179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125612#comment-15125612 ] ASF GitHub Bot commented on KAFKA-3179: --- GitHub user becketqin opened a pull request:

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15130010#comment-15130010 ] ASF GitHub Bot commented on KAFKA-2875: --- Github user ZoneMayor closed the pull request at:

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15130011#comment-15130011 ] ASF GitHub Bot commented on KAFKA-2875: --- GitHub user ZoneMayor reopened a pull request:

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15130084#comment-15130084 ] ASF GitHub Bot commented on KAFKA-3197: --- GitHub user becketqin opened a pull request:

[jira] [Commented] (KAFKA-3194) Validate security.inter.broker.protocol against the advertised.listeners protocols

[ https://issues.apache.org/jira/browse/KAFKA-3194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131393#comment-15131393 ] ASF GitHub Bot commented on KAFKA-3194: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3198) Ticket Renewal Thread exits prematurely due to inverted comparison

[ https://issues.apache.org/jira/browse/KAFKA-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131378#comment-15131378 ] ASF GitHub Bot commented on KAFKA-3198: --- GitHub user kunickiaj opened a pull request:

[jira] [Commented] (KAFKA-3186) Kafka authorizer should be aware of principal types it supports.

[ https://issues.apache.org/jira/browse/KAFKA-3186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131490#comment-15131490 ] ASF GitHub Bot commented on KAFKA-3186: --- GitHub user SinghAsDev opened a pull request:

[jira] [Commented] (KAFKA-3199) LoginManager should allow using an existing Subject

[ https://issues.apache.org/jira/browse/KAFKA-3199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131609#comment-15131609 ] ASF GitHub Bot commented on KAFKA-3199: --- GitHub user kunickiaj opened a pull request:

[jira] [Commented] (KAFKA-3198) Ticket Renewal Thread exits prematurely due to inverted comparison

[ https://issues.apache.org/jira/browse/KAFKA-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131813#comment-15131813 ] ASF GitHub Bot commented on KAFKA-3198: --- Github user kunickiaj closed the pull request at:

[jira] [Commented] (KAFKA-3198) Ticket Renewal Thread exits prematurely due to inverted comparison

[ https://issues.apache.org/jira/browse/KAFKA-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131814#comment-15131814 ] ASF GitHub Bot commented on KAFKA-3198: --- GitHub user kunickiaj reopened a pull request:

[jira] [Commented] (KAFKA-3198) Ticket Renewal Thread exits prematurely due to inverted comparison

[ https://issues.apache.org/jira/browse/KAFKA-3198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15131885#comment-15131885 ] ASF GitHub Bot commented on KAFKA-3198: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2522) ConsumerGroupCommand sends all output to STDOUT

[ https://issues.apache.org/jira/browse/KAFKA-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124749#comment-15124749 ] ASF GitHub Bot commented on KAFKA-2522: --- GitHub user melan opened a pull request:

[jira] [Commented] (KAFKA-3174) Re-evaluate the CRC32 class performance.

[ https://issues.apache.org/jira/browse/KAFKA-3174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124778#comment-15124778 ] ASF GitHub Bot commented on KAFKA-3174: --- GitHub user becketqin opened a pull request:

[jira] [Commented] (KAFKA-2522) ConsumerGroupCommand sends all output to STDOUT

[ https://issues.apache.org/jira/browse/KAFKA-2522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124746#comment-15124746 ] ASF GitHub Bot commented on KAFKA-2522: --- Github user melan closed the pull request at:

[jira] [Commented] (KAFKA-3169) Kafka broker throws OutOfMemory error with invalid SASL packet

[ https://issues.apache.org/jira/browse/KAFKA-3169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15124854#comment-15124854 ] ASF GitHub Bot commented on KAFKA-3169: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3164) Document client and mirrormaker upgrade procedure/requirements

[ https://issues.apache.org/jira/browse/KAFKA-3164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15125159#comment-15125159 ] ASF GitHub Bot commented on KAFKA-3164: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128638#comment-15128638 ] ASF GitHub Bot commented on KAFKA-3068: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3170) Default value of fetch_min_bytes in new consumer is 1024 while doc says it is 1

[ https://issues.apache.org/jira/browse/KAFKA-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15128641#comment-15128641 ] ASF GitHub Bot commented on KAFKA-3170: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3092) Rename SinkTask.onPartitionsAssigned/onPartitionsRevoked and Clarify Contract

[ https://issues.apache.org/jira/browse/KAFKA-3092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15130955#comment-15130955 ] ASF GitHub Bot commented on KAFKA-3092: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15129723#comment-15129723 ] ASF GitHub Bot commented on KAFKA-2875: --- GitHub user ZoneMayor reopened a pull request:

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15129722#comment-15129722 ] ASF GitHub Bot commented on KAFKA-2875: --- Github user ZoneMayor closed the pull request at:

[jira] [Commented] (KAFKA-3195) Transient test failure in OffsetCheckpointTest.testReadWrite

[ https://issues.apache.org/jira/browse/KAFKA-3195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15129646#comment-15129646 ] ASF GitHub Bot commented on KAFKA-3195: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3189) Kafka server returns UnknownServerException for inherited exceptions

[ https://issues.apache.org/jira/browse/KAFKA-3189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15129701#comment-15129701 ] ASF GitHub Bot commented on KAFKA-3189: --- GitHub user granthenke opened a pull request:

[jira] [Commented] (KAFKA-2143) Replicas get ahead of leader and fail

[ https://issues.apache.org/jira/browse/KAFKA-2143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122919#comment-15122919 ] ASF GitHub Bot commented on KAFKA-2143: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2221) Log the entire cause which caused a reconnect in the SimpleConsumer

[ https://issues.apache.org/jira/browse/KAFKA-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122923#comment-15122923 ] ASF GitHub Bot commented on KAFKA-2221: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2653) Stateful operations in the KStream DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122951#comment-15122951 ] ASF GitHub Bot commented on KAFKA-2653: --- Github user guozhangwang closed the pull request at:

[jira] [Commented] (KAFKA-948) ISR list in LeaderAndISR path not updated for partitions when Broker (which is not leader) is down

[ https://issues.apache.org/jira/browse/KAFKA-948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122731#comment-15122731 ] ASF GitHub Bot commented on KAFKA-948: -- Github user dibbhatt closed the pull request at:

[jira] [Commented] (KAFKA-2802) Add integration tests for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-2802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159573#comment-15159573 ] ASF GitHub Bot commented on KAFKA-2802: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3214) Add consumer system tests for compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159778#comment-15159778 ] ASF GitHub Bot commented on KAFKA-3214: --- GitHub user apovzner opened a pull request:

[jira] [Commented] (KAFKA-3245) need a way to specify the number of replicas for change log topics

[ https://issues.apache.org/jira/browse/KAFKA-3245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159815#comment-15159815 ] ASF GitHub Bot commented on KAFKA-3245: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2832) support exclude.internal.topics in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159809#comment-15159809 ] ASF GitHub Bot commented on KAFKA-2832: --- GitHub user vahidhashemian reopened a pull request:

[jira] [Commented] (KAFKA-2832) support exclude.internal.topics in new consumer

[ https://issues.apache.org/jira/browse/KAFKA-2832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159808#comment-15159808 ] ASF GitHub Bot commented on KAFKA-2832: --- Github user vahidhashemian closed the pull request at:

[jira] [Commented] (KAFKA-3046) add ByteBuffer Serializer

[ https://issues.apache.org/jira/browse/KAFKA-3046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159831#comment-15159831 ] ASF GitHub Bot commented on KAFKA-3046: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157534#comment-15157534 ] ASF GitHub Bot commented on KAFKA-3093: --- Github user hachikuji closed the pull request at:

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157535#comment-15157535 ] ASF GitHub Bot commented on KAFKA-3093: --- GitHub user hachikuji reopened a pull request:

[jira] [Commented] (KAFKA-3245) need a way to specify the number of replicas for change log topics

[ https://issues.apache.org/jira/browse/KAFKA-3245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157720#comment-15157720 ] ASF GitHub Bot commented on KAFKA-3245: --- GitHub user ymatsuda opened a pull request:

[jira] [Commented] (KAFKA-3248) AdminClient Blocks Forever in send Method

[ https://issues.apache.org/jira/browse/KAFKA-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157515#comment-15157515 ] ASF GitHub Bot commented on KAFKA-3248: --- GitHub user WarrenGreen opened a pull request:

[jira] [Commented] (KAFKA-3279) SASL implementation checks for unused System property java.security.auth.login.config

[ https://issues.apache.org/jira/browse/KAFKA-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163226#comment-15163226 ] ASF GitHub Bot commented on KAFKA-3279: --- GitHub user rajinisivaram opened a pull request:

[jira] [Commented] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

[ https://issues.apache.org/jira/browse/KAFKA-3278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15162775#comment-15162775 ] ASF GitHub Bot commented on KAFKA-3278: --- GitHub user tomdearman opened a pull request:

[jira] [Commented] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/KAFKA-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163348#comment-15163348 ] ASF GitHub Bot commented on KAFKA-3277: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3093) Keep track of connector and task status info, expose it via the REST API

[ https://issues.apache.org/jira/browse/KAFKA-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15160279#comment-15160279 ] ASF GitHub Bot commented on KAFKA-3093: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3259) KIP-31/KIP-32 clean-ups

[ https://issues.apache.org/jira/browse/KAFKA-3259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163566#comment-15163566 ] ASF GitHub Bot commented on KAFKA-3259: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15163922#comment-15163922 ] ASF GitHub Bot commented on KAFKA-3018: --- Github user choang closed the pull request at:

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15160018#comment-15160018 ] ASF GitHub Bot commented on KAFKA-3018: --- GitHub user choang opened a pull request:

[jira] [Commented] (KAFKA-3007) Implement max.poll.records for new consumer (KIP-41)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159888#comment-15159888 ] ASF GitHub Bot commented on KAFKA-3007: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3272) Add debugging options to kafka-run-class.sh so we can easily run remote debugging

[ https://issues.apache.org/jira/browse/KAFKA-3272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159905#comment-15159905 ] ASF GitHub Bot commented on KAFKA-3272: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15160048#comment-15160048 ] ASF GitHub Bot commented on KAFKA-2698: --- GitHub user hachikuji opened a pull request:

[jira] [Commented] (KAFKA-3256) Large number of system test failures

[ https://issues.apache.org/jira/browse/KAFKA-3256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157780#comment-15157780 ] ASF GitHub Bot commented on KAFKA-3256: --- GitHub user becketqin opened a pull request:

[jira] [Commented] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/KAFKA-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15160241#comment-15160241 ] ASF GitHub Bot commented on KAFKA-3277: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-3272) Add debugging options to kafka-run-class.sh so we can easily run remote debugging

[ https://issues.apache.org/jira/browse/KAFKA-3272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159515#comment-15159515 ] ASF GitHub Bot commented on KAFKA-3272: --- GitHub user christian-posta opened a pull request:

[jira] [Commented] (KAFKA-3242) "Add Partition" log message doesn't actually indicate adding a partition

[ https://issues.apache.org/jira/browse/KAFKA-3242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15159629#comment-15159629 ] ASF GitHub Bot commented on KAFKA-3242: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3214) Add consumer system tests for compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169889#comment-15169889 ] ASF GitHub Bot commented on KAFKA-3214: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3300) Calculate the initial/max size of offset index files and reduce the memory footprint for memory mapped index files.

[ https://issues.apache.org/jira/browse/KAFKA-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171293#comment-15171293 ] ASF GitHub Bot commented on KAFKA-3300: --- GitHub user becketqin opened a pull request:

[jira] [Commented] (KAFKA-3286) Add plugin to quickly check for outdated dependencies

[ https://issues.apache.org/jira/browse/KAFKA-3286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167486#comment-15167486 ] ASF GitHub Bot commented on KAFKA-3286: --- GitHub user granthenke opened a pull request:

[jira] [Commented] (KAFKA-3280) KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use

[ https://issues.apache.org/jira/browse/KAFKA-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15166588#comment-15166588 ] ASF GitHub Bot commented on KAFKA-3280: --- GitHub user rwhaling opened a pull request:

[jira] [Commented] (KAFKA-3257) bootstrap-test-env.sh version check fails when grep has --colour option enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15166721#comment-15166721 ] ASF GitHub Bot commented on KAFKA-3257: --- GitHub user zhuchen1018 opened a pull request:

[jira] [Commented] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15166680#comment-15166680 ] ASF GitHub Bot commented on KAFKA-2698: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3281) Improve message of stop scripts when no processes are running

[ https://issues.apache.org/jira/browse/KAFKA-3281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15166952#comment-15166952 ] ASF GitHub Bot commented on KAFKA-3281: --- GitHub user sasakitoa opened a pull request:

[jira] [Commented] (KAFKA-3273) MessageFormatter and MessageReader interfaces should be resilient to changes

[ https://issues.apache.org/jira/browse/KAFKA-3273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167214#comment-15167214 ] ASF GitHub Bot commented on KAFKA-3273: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-3291) DumpLogSegment tool should also provide an option to only verify index sanity.

[ https://issues.apache.org/jira/browse/KAFKA-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172169#comment-15172169 ] ASF GitHub Bot commented on KAFKA-3291: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172571#comment-15172571 ] ASF GitHub Bot commented on KAFKA-3133: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172729#comment-15172729 ] ASF GitHub Bot commented on KAFKA-3236: --- Github user knusbaum closed the pull request at:

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172730#comment-15172730 ] ASF GitHub Bot commented on KAFKA-3236: --- GitHub user knusbaum reopened a pull request:

[jira] [Commented] (KAFKA-3192) Add implicit unlimited windowed aggregation for KStream

[ https://issues.apache.org/jira/browse/KAFKA-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172703#comment-15172703 ] ASF GitHub Bot commented on KAFKA-3192: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3307) Add ProtocolVersion request/response and server side handling.

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172880#comment-15172880 ] ASF GitHub Bot commented on KAFKA-3307: --- GitHub user SinghAsDev reopened a pull request:

[jira] [Commented] (KAFKA-3307) Add ProtocolVersion request/response and server side handling.

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172879#comment-15172879 ] ASF GitHub Bot commented on KAFKA-3307: --- Github user SinghAsDev closed the pull request at:

[jira] [Commented] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

[ https://issues.apache.org/jira/browse/KAFKA-3278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168803#comment-15168803 ] ASF GitHub Bot commented on KAFKA-3278: --- GitHub user tomdearman opened a pull request:

[jira] [Commented] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

[ https://issues.apache.org/jira/browse/KAFKA-3278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168748#comment-15168748 ] ASF GitHub Bot commented on KAFKA-3278: --- Github user tomdearman closed the pull request at:

[jira] [Commented] (KAFKA-3299) KafkaConnect: DistributedHerder shouldn't wait forever to read configs after rebalance

[ https://issues.apache.org/jira/browse/KAFKA-3299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15170172#comment-15170172 ] ASF GitHub Bot commented on KAFKA-3299: --- GitHub user gwenshap opened a pull request:

[jira] [Commented] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

[ https://issues.apache.org/jira/browse/KAFKA-3278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15170045#comment-15170045 ] ASF GitHub Bot commented on KAFKA-3278: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3201) Add system test for KIP-31 and KIP-32 - Upgrade Test

[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15170091#comment-15170091 ] ASF GitHub Bot commented on KAFKA-3201: --- GitHub user apovzner opened a pull request:

[jira] [Commented] (KAFKA-3260) Increase the granularity of commit for SourceTask

[ https://issues.apache.org/jira/browse/KAFKA-3260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157935#comment-15157935 ] ASF GitHub Bot commented on KAFKA-3260: --- GitHub user jcustenborder opened a pull request:

[jira] [Commented] (KAFKA-3256) Large number of system test failures

[ https://issues.apache.org/jira/browse/KAFKA-3256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157972#comment-15157972 ] ASF GitHub Bot commented on KAFKA-3256: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3196) KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157965#comment-15157965 ] ASF GitHub Bot commented on KAFKA-3196: --- GitHub user apovzner opened a pull request:

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157349#comment-15157349 ] ASF GitHub Bot commented on KAFKA-1476: --- GitHub user christian-posta opened a pull request:

[jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169074#comment-15169074 ] ASF GitHub Bot commented on KAFKA-3297: --- GitHub user noslowerdna opened a pull request:

[jira] [Commented] (KAFKA-3280) KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use

[ https://issues.apache.org/jira/browse/KAFKA-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168304#comment-15168304 ] ASF GitHub Bot commented on KAFKA-3280: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3292) ClientQuotaManager.getOrCreateQuotaSensors() may return a null ClientSensors.throttleTimeSensor

[ https://issues.apache.org/jira/browse/KAFKA-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168270#comment-15168270 ] ASF GitHub Bot commented on KAFKA-3292: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3243) Fix Kafka basic ops documentation for Mirror maker, blacklist is not supported for new consumers

[ https://issues.apache.org/jira/browse/KAFKA-3243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169497#comment-15169497 ] ASF GitHub Bot commented on KAFKA-3243: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3292) ClientQuotaManager.getOrCreateQuotaSensors() may return a null ClientSensors.throttleTimeSensor

[ https://issues.apache.org/jira/browse/KAFKA-3292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168202#comment-15168202 ] ASF GitHub Bot commented on KAFKA-3292: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-3291) DumpLogSegment tool should also provide an option to only verify index sanity.

[ https://issues.apache.org/jira/browse/KAFKA-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168160#comment-15168160 ] ASF GitHub Bot commented on KAFKA-3291: --- GitHub user Parth-Brahmbhatt opened a pull request:

[jira] [Commented] (KAFKA-3255) Extra unit tests for NetworkClient.connectionDelay(Node node, long now)

[ https://issues.apache.org/jira/browse/KAFKA-3255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15157408#comment-15157408 ] ASF GitHub Bot commented on KAFKA-3255: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-627) Make UnknownTopicOrPartitionException a WARN in broker

[ https://issues.apache.org/jira/browse/KAFKA-627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15146725#comment-15146725 ] ASF GitHub Bot commented on KAFKA-627: -- GitHub user kichristensen opened a pull request:

[jira] [Commented] (KAFKA-3235) Unclosed stream in AppInfoParser static block

[ https://issues.apache.org/jira/browse/KAFKA-3235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15146726#comment-15146726 ] ASF GitHub Bot commented on KAFKA-3235: --- GitHub user kichristensen opened a pull request:

[jira] [Commented] (KAFKA-3263) Add Markdown support for ConfigDef

[ https://issues.apache.org/jira/browse/KAFKA-3263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15158412#comment-15158412 ] ASF GitHub Bot commented on KAFKA-3263: --- GitHub user jcustenborder opened a pull request:

[jira] [Commented] (KAFKA-3066) Add Demo Examples for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15110168#comment-15110168 ] ASF GitHub Bot commented on KAFKA-3066: --- GitHub user guozhangwang opened a pull request:

[jira] [Commented] (KAFKA-3080) ConsoleConsumerTest.test_version system test fails consistently

[ https://issues.apache.org/jira/browse/KAFKA-3080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1531#comment-1531 ] ASF GitHub Bot commented on KAFKA-3080: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-2146) adding partition did not find the correct startIndex

[ https://issues.apache.org/jira/browse/KAFKA-2146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15111670#comment-15111670 ] ASF GitHub Bot commented on KAFKA-2146: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3136) Rename KafkaStreaming to KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-3136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113056#comment-15113056 ] ASF GitHub Bot commented on KAFKA-3136: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113009#comment-15113009 ] ASF GitHub Bot commented on KAFKA-3068: --- GitHub user enothereska opened a pull request:

[jira] [Commented] (KAFKA-3134) Missing required configuration "value.deserializer" when initializing a KafkaConsumer with a valid "valueDeserializer"

[ https://issues.apache.org/jira/browse/KAFKA-3134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15112919#comment-15112919 ] ASF GitHub Bot commented on KAFKA-3134: --- GitHub user happymap opened a pull request:

[jira] [Commented] (KAFKA-3140) PatternSyntaxException thrown in MM, causes MM to hang

[ https://issues.apache.org/jira/browse/KAFKA-3140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15113231#comment-15113231 ] ASF GitHub Bot commented on KAFKA-3140: --- GitHub user SinghAsDev opened a pull request:

[jira] [Commented] (KAFKA-3076) BrokerChangeListener should log the brokers in order

[ https://issues.apache.org/jira/browse/KAFKA-3076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116228#comment-15116228 ] ASF GitHub Bot commented on KAFKA-3076: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3100) Broker.createBroker should work if json is version > 2, but still compatible

[ https://issues.apache.org/jira/browse/KAFKA-3100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116257#comment-15116257 ] ASF GitHub Bot commented on KAFKA-3100: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3125) Exception Hierarchy for Streams

[ https://issues.apache.org/jira/browse/KAFKA-3125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116358#comment-15116358 ] ASF GitHub Bot commented on KAFKA-3125: --- GitHub user guozhangwang opened a pull request:

[jira] [Commented] (KAFKA-3122) Memory leak in `Sender.completeBatch` on TOPIC_AUTHORIZATION_FAILED

[ https://issues.apache.org/jira/browse/KAFKA-3122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107701#comment-15107701 ] ASF GitHub Bot commented on KAFKA-3122: --- GitHub user ijuma opened a pull request:

[jira] [Commented] (KAFKA-3122) Memory leak in `Sender.completeBatch` on TOPIC_AUTHORIZATION_FAILED

[ https://issues.apache.org/jira/browse/KAFKA-3122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15108122#comment-15108122 ] ASF GitHub Bot commented on KAFKA-3122: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3121) KStream DSL API Improvement

[ https://issues.apache.org/jira/browse/KAFKA-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15109381#comment-15109381 ] ASF GitHub Bot commented on KAFKA-3121: --- GitHub user guozhangwang opened a pull request:

<    9   10   11   12   13   14   15   16   17   18   >