[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

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

[jira] [Commented] (KAFKA-5765) Move merge() from StreamsBuilder to KStream

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

[jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector()

[ https://issues.apache.org/jira/browse/KAFKA-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5863: -- Description: Here is the call chain: {code}

[jira] [Commented] (KAFKA-5778) Kafka cluster is not responding when one broker hangs and resulted in too many connections in close_wait in other brokers

[ https://issues.apache.org/jira/browse/KAFKA-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172583#comment-16172583 ] Jungbae Jun commented on KAFKA-5778: I patched my kafka version by 0.10.2.1 and the problem has not

[jira] [Commented] (KAFKA-5937) Improve ProcessorStateManager exception handling

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

[jira] [Commented] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-5914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172500#comment-16172500 ] Apurva Mehta commented on KAFKA-5914: - This is being descoped from the 1.0.0 release, since actually

[jira] [Updated] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse

[ https://issues.apache.org/jira/browse/KAFKA-5914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5914: Fix Version/s: (was: 1.0.0) 1.1.0 > Return MessageFormatVersion and

[jira] [Updated] (KAFKA-5937) Improve ProcessorStateManager exception handling

[ https://issues.apache.org/jira/browse/KAFKA-5937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5937: --- Description: We identified the follow issues: - constructor calls

[jira] [Commented] (KAFKA-5936) KafkaProducer should not wrap InterruptedException in close() with KafkaException

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

[jira] [Commented] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172332#comment-16172332 ] Fernando Vega commented on KAFKA-5407: -- Also this is 6 brokers, do I have to apply this change to 6

[jira] [Updated] (KAFKA-5935) Kafka connect should provide configurable CONNECTOR_EXCLUDES

[ https://issues.apache.org/jira/browse/KAFKA-5935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen He updated KAFKA-5935: --- Labels: connector (was: ) > Kafka connect should provide configurable CONNECTOR_EXCLUDES >

[jira] [Updated] (KAFKA-5935) Kafka connect should provide configurable CONNECTOR_EXCLUDES

[ https://issues.apache.org/jira/browse/KAFKA-5935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chen He updated KAFKA-5935: --- Description: In o.a.kafka.connect.runtime.rest.resources.ConnectorPluginsResource, there is a

[jira] [Created] (KAFKA-5935) Kafka connect should provide configurable CONNECTOR_EXCLUDES

Chen He created KAFKA-5935: -- Summary: Kafka connect should provide configurable CONNECTOR_EXCLUDES Key: KAFKA-5935 URL: https://issues.apache.org/jira/browse/KAFKA-5935 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5934) Cross build for scala 2.12

Srdan Srepfler created KAFKA-5934: - Summary: Cross build for scala 2.12 Key: KAFKA-5934 URL: https://issues.apache.org/jira/browse/KAFKA-5934 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class

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

[jira] [Created] (KAFKA-5933) Move timeout and validate_only protocol fields into CommonFields class

Jakub Scholz created KAFKA-5933: --- Summary: Move timeout and validate_only protocol fields into CommonFields class Key: KAFKA-5933 URL: https://issues.apache.org/jira/browse/KAFKA-5933 Project: Kafka

[jira] [Commented] (KAFKA-1736) Improve parition-broker assignment strategy for better availaility in majority durability modes

[ https://issues.apache.org/jira/browse/KAFKA-1736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172168#comment-16172168 ] Elias Levy commented on KAFKA-1736: --- Looks like discussion of this important topic died a few years ago.

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172134#comment-16172134 ] Sébastien Launay commented on KAFKA-4950: - I am also getting such an error sporadically when using

[jira] [Commented] (KAFKA-4950) ConcurrentModificationException when iterating over Kafka Metrics

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

[jira] [Assigned] (KAFKA-5784) Add a sensor for dropped records in window stores

[ https://issues.apache.org/jira/browse/KAFKA-5784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5784: -- Assignee: Bill Bejeck > Add a sensor for dropped records in window stores >

[jira] [Assigned] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners

[ https://issues.apache.org/jira/browse/KAFKA-5932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-5932: -- Assignee: Bill Bejeck > Avoid call fetchPrevious in FlushListeners >

[jira] [Assigned] (KAFKA-5862) Remove ZK dependency from Streams reset tool

[ https://issues.apache.org/jira/browse/KAFKA-5862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5862: -- Assignee: Bill Bejeck (was: Matthias J. Sax) > Remove ZK dependency from Streams

[jira] [Commented] (KAFKA-5735) Client-ids are not handled consistently by clients and broker

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

[jira] [Updated] (KAFKA-5397) streams are not recovering from LockException during rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5397: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5156 > streams are not recovering from

[jira] [Assigned] (KAFKA-5397) streams are not recovering from LockException during rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5397: -- Assignee: Matthias J. Sax > streams are not recovering from LockException during

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172057#comment-16172057 ] Randall Hauch commented on KAFKA-5716: -- {quote} I am! And couldn't live without it I cannot afford

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16172056#comment-16172056 ] Randall Hauch commented on KAFKA-5716: -- {quote} I am! And couldn't live without it I cannot afford

[jira] [Updated] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4593: --- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5156 > Task migration during rebalance

[jira] [Assigned] (KAFKA-4593) Task migration during rebalance callback process could lead the obsoleted task's IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-4593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4593: -- Assignee: Matthias J. Sax > Task migration during rebalance callback process could

[jira] [Updated] (KAFKA-5695) Test DeleteRecordsRequest in AuthorizerIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5695: Fix Version/s: 1.0.0 > Test DeleteRecordsRequest in AuthorizerIntegrationTest >

[jira] [Updated] (KAFKA-5843) Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to true

[ https://issues.apache.org/jira/browse/KAFKA-5843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5843: Fix Version/s: 1.0.0 > Mx4jLoader.maybeLoad should only be executed if kafka_mx4jenable is set to > true >

[jira] [Updated] (KAFKA-5879) Controller should read the latest IsrChangeNotification znodes when handling IsrChangeNotification event

[ https://issues.apache.org/jira/browse/KAFKA-5879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5879: Fix Version/s: 1.0.0 > Controller should read the latest IsrChangeNotification znodes when handling >

[jira] [Updated] (KAFKA-5877) Controller should only update reassignment znode if there is change in the reassignment data

[ https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5877: Fix Version/s: 1.0.0 > Controller should only update reassignment znode if there is change in the >

[jira] [Updated] (KAFKA-5163) Support replicas movement between log directories (KIP-113)

[ https://issues.apache.org/jira/browse/KAFKA-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5163: Fix Version/s: 1.0.0 > Support replicas movement between log directories (KIP-113) >

[jira] [Updated] (KAFKA-4691) ProducerInterceptor.onSend() is called after key and value are serialized

[ https://issues.apache.org/jira/browse/KAFKA-4691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4691: --- Labels: (was: easyfix) > ProducerInterceptor.onSend() is called after key and value are

[jira] [Commented] (KAFKA-5885) NPE in ZKClient

[ https://issues.apache.org/jira/browse/KAFKA-5885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171849#comment-16171849 ] Mickael Maison commented on KAFKA-5885: --- So we hit this issue in July one night and the ops engineer

[jira] [Created] (KAFKA-5932) Avoid call fetchPrevious in FlushListeners

Guozhang Wang created KAFKA-5932: Summary: Avoid call fetchPrevious in FlushListeners Key: KAFKA-5932 URL: https://issues.apache.org/jira/browse/KAFKA-5932 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-5874) Incorrect command line handling

[ https://issues.apache.org/jira/browse/KAFKA-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171662#comment-16171662 ] Viliam Durina commented on KAFKA-5874: -- Thanks for the fix. But it should not only check there's at

[jira] [Updated] (KAFKA-5864) ReplicaFetcherThread should not die due to replica in offline log directory

[ https://issues.apache.org/jira/browse/KAFKA-5864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5864: --- Fix Version/s: 1.0.0 > ReplicaFetcherThread should not die due to replica in offline log directory >

[jira] [Created] (KAFKA-5931) Deprecate KTable#to and KTable#through

Damian Guy created KAFKA-5931: - Summary: Deprecate KTable#to and KTable#through Key: KAFKA-5931 URL: https://issues.apache.org/jira/browse/KAFKA-5931 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-5931) Deprecate KTable#to and KTable#through

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

[jira] [Commented] (KAFKA-5922) Add SessionWindowedKStream

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

[jira] [Created] (KAFKA-5930) Decide on consistent method for determining elapsed time.

Koen De Groote created KAFKA-5930: - Summary: Decide on consistent method for determining elapsed time. Key: KAFKA-5930 URL: https://issues.apache.org/jira/browse/KAFKA-5930 Project: Kafka

[jira] [Commented] (KAFKA-3700) CRL support

[ https://issues.apache.org/jira/browse/KAFKA-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171453#comment-16171453 ] Antony Stubbs commented on KAFKA-3700: -- Another option would be to implement OCSP

[jira] [Commented] (KAFKA-5921) Add Materialized overloads to WindowedKStream

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

[jira] [Commented] (KAFKA-4320) Log compaction docs update

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

[jira] [Commented] (KAFKA-4320) Log compaction docs update

[ https://issues.apache.org/jira/browse/KAFKA-4320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171410#comment-16171410 ] Jakub Scholz commented on KAFKA-4320: - [~cotedm] I created 2 PRs for the 0.9.0 and 0.10.0 branches

[jira] [Commented] (KAFKA-4320) Log compaction docs update

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

[jira] [Commented] (KAFKA-4320) Log compaction docs update

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

[jira] [Commented] (KAFKA-5716) Connect: When SourceTask.commit it is possible not everthing from SourceTask.poll has been sent

[ https://issues.apache.org/jira/browse/KAFKA-5716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171249#comment-16171249 ] Per Steffensen commented on KAFKA-5716: --- FWIW bq. WorkerSourceTask doesn't have synchronization

[jira] [Assigned] (KAFKA-4932) Add UUID Serde

[ https://issues.apache.org/jira/browse/KAFKA-4932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Scholz reassigned KAFKA-4932: --- Assignee: Jakub Scholz > Add UUID Serde > -- > > Key: KAFKA-4932

[jira] [Commented] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign

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

[jira] [Created] (KAFKA-5929) Save pre-assignment to file to avoid too long text to display when do topic partition reassign

Genmao Yu created KAFKA-5929: Summary: Save pre-assignment to file to avoid too long text to display when do topic partition reassign Key: KAFKA-5929 URL: https://issues.apache.org/jira/browse/KAFKA-5929

[jira] [Assigned] (KAFKA-5867) Kafka Connect applications should log info message when starting up

[ https://issues.apache.org/jira/browse/KAFKA-5867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis reassigned KAFKA-5867: - Assignee: Konstantine Karantasis > Kafka Connect applications should log

[jira] [Comment Edited] (KAFKA-4714) Implement remaining KIP-66 SMTs

[ https://issues.apache.org/jira/browse/KAFKA-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171189#comment-16171189 ] Dhananjay Patkar edited comment on KAFKA-4714 at 9/19/17 6:43 AM: -- Thanks

[jira] [Commented] (KAFKA-4714) Implement remaining KIP-66 SMTs

[ https://issues.apache.org/jira/browse/KAFKA-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16171189#comment-16171189 ] Dhananjay Patkar commented on KAFKA-4714: - Thanks [~ewencp] for quick reply. I have a use case,

[jira] [Commented] (KAFKA-5914) Return MessageFormatVersion and MessageMaxBytes in MetadataResponse

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