[jira] [Commented] (KAFKA-3392) ConsumerRecords iterator throws NoSuchElementException when a TopicPartition is empty

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

[jira] [Commented] (KAFKA-2551) Unclean leader election docs outdated

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

[jira] [Commented] (KAFKA-3202) Add system test for KIP-31 and KIP-32 - Change message format version on the fly

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

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

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

[jira] [Commented] (KAFKA-3393) Update site docs and javadoc based on max.block.ms changes

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

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

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

[jira] [Commented] (KAFKA-3395) prefix job id to internal topic names

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

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

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

[jira] [Commented] (KAFKA-3047) Explicit offset assignment in Log.append can corrupt the log

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

[jira] [Commented] (KAFKA-3402) Restore behaviour of MetadataCache.getTopicMetadata when unsupported security protocol is received

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

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

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

[jira] [Commented] (KAFKA-3395) prefix job id to internal topic names

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

[jira] [Commented] (KAFKA-3387) Update GetOffsetShell tool to not rely on old producer.

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

[jira] [Commented] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

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

[jira] [Commented] (KAFKA-3354) Streams system tests fail in trunk

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

[jira] [Commented] (KAFKA-3354) Streams system tests fail in trunk

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

[jira] [Commented] (KAFKA-3237) ConfigDef validators require a default value

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

[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=15185926#comment-15185926 ] ASF GitHub Bot commented on KAFKA-3197: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3343) GroupMetadataManager should use NoTimestamp for message v0

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

[jira] [Commented] (KAFKA-3358) Only request metadata updates once we have topics or a pattern subscription

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

[jira] [Commented] (KAFKA-3371) ClientCompatibilityTest system test failing since KIP-31/KIP-32 was merged

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

[jira] [Commented] (KAFKA-3330) Truncate log cleaner offset checkpoint if the log is truncated

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

[jira] [Commented] (KAFKA-3403) Upgrade ZkClient to 0.8

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

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

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

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

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

[jira] [Commented] (KAFKA-3403) Upgrade ZkClient to 0.8

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

[jira] [Commented] (KAFKA-3336) Unify ser/de pair classes into one serde class

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

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

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

[jira] [Commented] (KAFKA-3402) Restore behaviour of MetadataCache.getTopicMetadata when unsupported security protocol is received

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

[jira] [Commented] (KAFKA-3407) ErrorLoggingCallback trims helpful diagnostic information.

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

[jira] [Commented] (KAFKA-3394) Broker fails to parse Null Metadata in OffsetCommit requests

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

[jira] [Commented] (KAFKA-2982) Mark the old Scala producer and related classes as deprecated

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

[jira] [Commented] (KAFKA-3375) Suppress and fix compiler warnings where reasonable and tweak compiler settings

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

[jira] [Commented] (KAFKA-3397) add missing 'REQUIRED' for tools.GetOffsetShell

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

[jira] [Commented] (KAFKA-3398) avoid just sending to one partition when record key is empty string

[ https://issues.apache.org/jira/browse/KAFKA-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15194669#comment-15194669 ] ASF GitHub Bot commented on KAFKA-3398: --- GitHub user vesense 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=15196842#comment-15196842 ] ASF GitHub Bot commented on KAFKA-3260: --- GitHub user ewencp opened a pull request:

[jira] [Commented] (KAFKA-3047) Explicit offset assignment in Log.append can corrupt the log

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

[jira] [Commented] (KAFKA-3411) Streams: stop using "job" terminology, rename job.id to application.id

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

[jira] [Commented] (KAFKA-2960) DelayedProduce may cause message loss during repeated leader change

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

[jira] [Commented] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

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

[jira] [Commented] (KAFKA-3357) Update to Scala 2.11.8

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

[jira] [Commented] (KAFKA-3388) Producer should only timeout a batch in the accumulator when metadata is missing.

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

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

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

[jira] [Commented] (KAFKA-3336) Unify ser/de pair classes into one serde class

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

[jira] [Commented] (KAFKA-3013) Display the topic-partition in the exception message for expired batches in recordAccumulator

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

[jira] [Commented] (KAFKA-3419) New consumer javadoc unclear on topic subscription vs partition assignment

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

[jira] [Commented] (KAFKA-3425) Add missing notes to upgrade docs

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

[jira] [Commented] (KAFKA-3381) Add system test for SimpleConsumerShell

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

[jira] [Commented] (KAFKA-3471) min.insync.replicas isn't respected when there's a delaying follower who still in ISR

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

[jira] [Commented] (KAFKA-3475) Introduce our own `MiniKdc`

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

[jira] [Commented] (KAFKA-1981) Make log compaction point configurable

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

[jira] [Commented] (KAFKA-3486) Autocommit does not execute periodically when partitions are manually assigned

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

[jira] [Commented] (KAFKA-3526) REST APIs return object representation instead of string for config values, default values and recommended values

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

[jira] [Commented] (KAFKA-3497) Streams ProcessorContext should support forward() based on child name

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

[jira] [Commented] (KAFKA-3488) commitAsync() fails if metadata update creates new SASL/SSL connection

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

[jira] [Commented] (KAFKA-3528) AbstractCoordinator wakeup during rebalance can cause spurious rebalances

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

[jira] [Commented] (KAFKA-3510) OffsetIndex thread safety

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

[jira] [Commented] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

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

[jira] [Commented] (KAFKA-3521) Better handling NPEs in Streams DSL implementation

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

[jira] [Commented] (KAFKA-3439) Document possible exception thrown in public APIs

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

[jira] [Commented] (KAFKA-3439) Document possible exception thrown in public APIs

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

[jira] [Commented] (KAFKA-3549) Close consumers instantiated in consumer tests

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

[jira] [Commented] (KAFKA-3461) Fix typos in Kafka web documentations

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

[jira] [Commented] (KAFKA-3504) Changelog partition configured to enable log compaction

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

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

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

[jira] [Commented] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in producer

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

[jira] [Commented] (KAFKA-3505) Set curRecord in punctuate() functions

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

[jira] [Commented] (KAFKA-3512) Add a foreach() operator in Kafka Streams DSL

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

[jira] [Commented] (KAFKA-3519) Refactor Transformer templates to return the same strong-typed value.

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

[jira] [Commented] (KAFKA-3338) Add print and writeAsText functions to the Streams DSL

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

[jira] [Commented] (KAFKA-3512) Add a foreach() operator in Kafka Streams DSL

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

[jira] [Commented] (KAFKA-3506) Kafka Connect Task Restart API

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

[jira] [Commented] (KAFKA-3489) Update request metrics if client closes connection while broker response is in flight

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

[jira] [Commented] (KAFKA-3505) Set curRecord in punctuate() functions

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

[jira] [Commented] (KAFKA-3477) Add customizable StreamPartition into #to functions of Streams DSL

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

[jira] [Commented] (KAFKA-3497) Streams ProcessorContext should support forward() based on child name

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

[jira] [Commented] (KAFKA-3533) Kafka Consumer Config validation should be AND not OR

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

[jira] [Commented] (KAFKA-3528) AbstractCoordinator wakeup during rebalance can cause spurious rebalances

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

[jira] [Commented] (KAFKA-3470) Consumer group coordinator should take commit requests as effective as heartbeats

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

[jira] [Commented] (KAFKA-3533) Kafka Consumer Config validation should be AND not OR

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

[jira] [Commented] (KAFKA-3521) Better handling NPEs in Streams DSL implementation

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

[jira] [Commented] (KAFKA-3480) Autogenerate metrics documentation

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

[jira] [Commented] (KAFKA-3519) Refactor Transformer templates to return the same strong-typed value.

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

[jira] [Commented] (KAFKA-3160) Kafka LZ4 framing code miscalculates header checksum

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

[jira] [Commented] (KAFKA-3163) KIP-33 - Add a time based log index to Kafka

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

[jira] [Commented] (KAFKA-3414) Return of MetadataCache.getAliveBrokers should not be mutated by cache updates

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

[jira] [Commented] (KAFKA-2982) Mark the old Scala producer and related classes as deprecated

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

[jira] [Commented] (KAFKA-3411) Streams: stop using "job" terminology, rename job.id to application.id

[ https://issues.apache.org/jira/browse/KAFKA-3411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15200014#comment-15200014 ] ASF GitHub Bot commented on KAFKA-3411: --- 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=15197455#comment-15197455 ] ASF GitHub Bot commented on KAFKA-2832: --- GitHub user edoardocomar opened a pull request:

[jira] [Commented] (KAFKA-3422) Add overloading functions for each operator not requiring serialization

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

[jira] [Commented] (KAFKA-3378) Client blocks forever if SocketChannel connects instantly

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

[jira] [Commented] (KAFKA-2370) Add pause/unpause connector support

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

[jira] [Commented] (KAFKA-3427) broker can return incorrect version of fetch response when the broker hits an unknown exception

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

[jira] [Commented] (KAFKA-3383) Producer should not remove an in flight request before successfully parsing the response.

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

[jira] [Commented] (KAFKA-3373) Add `log` prefix to KIP-31/32 configs

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

[jira] [Commented] (KAFKA-3400) Topic stop working / can't describe topic

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

[jira] [Commented] (KAFKA-3427) broker can return incorrect version of fetch response when the broker hits an unknown exception

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

[jira] [Commented] (KAFKA-3415) AdminOperationException when altering Topic with same number of partitions

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

[jira] [Commented] (KAFKA-3424) Add CORS support to Connect REST API

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

[jira] [Commented] (KAFKA-3250) release tarball is unnecessarily large due to duplicate libraries

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

<    11   12   13   14   15   16   17   18   19   20   >