[jira] [Updated] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-5657: - Labels: needs-kip (was: needs-kip newbie) > Connect REST API should include the

[jira] [Assigned] (KAFKA-5657) Connect REST API should include the connector type when describing a connector

[ https://issues.apache.org/jira/browse/KAFKA-5657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-5657: Assignee: Ted Yu > Connect REST API should include the connector type when

[jira] [Commented] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175839#comment-16175839 ] Ewen Cheslack-Postava commented on KAFKA-5538: -- [~Aegeaner] I like the idea, but let me

[jira] [Commented] (KAFKA-5330) Use per-task converters in Connect

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

[jira] [Resolved] (KAFKA-5330) Use per-task converters in Connect

[ https://issues.apache.org/jira/browse/KAFKA-5330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5330. -- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request

[jira] [Resolved] (KAFKA-5821) Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls

[ https://issues.apache.org/jira/browse/KAFKA-5821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5821. --- Resolution: Cannot Reproduce > Intermittent test failure in SaslPlainSslEndToEndAuthorizationTest.testAcls >

[jira] [Updated] (KAFKA-5802) ScramServerCallbackHandler#handle should check username not being null before calling credentialCache.get()

[ https://issues.apache.org/jira/browse/KAFKA-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-5802: -- Description: {code} String username = null; for (Callback callback : callbacks) {

[jira] [Updated] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers

[ https://issues.apache.org/jira/browse/KAFKA-5960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5960: --- Fix Version/s: 1.0.0 > Producer uses unsupported ProduceRequest version against older brokers

[jira] [Created] (KAFKA-5960) Producer uses unsupported ProduceRequest version against older brokers

Jason Gustafson created KAFKA-5960: -- Summary: Producer uses unsupported ProduceRequest version against older brokers Key: KAFKA-5960 URL: https://issues.apache.org/jira/browse/KAFKA-5960 Project:

[jira] [Created] (KAFKA-5959) NPE in NetworkClient

Xavier Léauté created KAFKA-5959: Summary: NPE in NetworkClient Key: KAFKA-5959 URL: https://issues.apache.org/jira/browse/KAFKA-5959 Project: Kafka Issue Type: Bug Components:

[jira] [Created] (KAFKA-5958) User StoreListener not available for global stores

Matthias J. Sax created KAFKA-5958: -- Summary: User StoreListener not available for global stores Key: KAFKA-5958 URL: https://issues.apache.org/jira/browse/KAFKA-5958 Project: Kafka Issue

[jira] [Commented] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch

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

[jira] [Updated] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch

[ https://issues.apache.org/jira/browse/KAFKA-5957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5957: --- Priority: Critical (was: Major) > Producer IllegalStateException due to second deallocate after

[jira] [Commented] (KAFKA-3999) Consumer bytes-fetched metric uses decompressed message size

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

[jira] [Updated] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch

[ https://issues.apache.org/jira/browse/KAFKA-5957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5957: --- Component/s: producer > Producer IllegalStateException due to second deallocate after

[jira] [Created] (KAFKA-5957) Producer IllegalStateException due to second deallocate after aborting a batch

Jason Gustafson created KAFKA-5957: -- Summary: Producer IllegalStateException due to second deallocate after aborting a batch Key: KAFKA-5957 URL: https://issues.apache.org/jira/browse/KAFKA-5957

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

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175646#comment-16175646 ] Guozhang Wang commented on KAFKA-5886: -- Thanks for the update. > Introduce delivery.timeout.ms

[jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175625#comment-16175625 ] Randall Hauch commented on KAFKA-4107: -- [~slionb], I think that

[jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175520#comment-16175520 ] Alla Tumarkin commented on KAFKA-4107: -- Additional feedback from a user: "What we are looking for is

[jira] [Commented] (KAFKA-5913) Add RecordMetadataNotAvailableException to indicate that ProduceResponse did not contain offset and timestamp information

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

[jira] [Commented] (KAFKA-5950) AdminClient should retry based on returned error codes

[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175489#comment-16175489 ] Ismael Juma commented on KAFKA-5950: [~andrey.dyach...@gmail.com], sure. It may make sense to do

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175474#comment-16175474 ] Jiangjie Qin commented on KAFKA-2200: - [~andy.chamb...@fundingcircle.com] Feel free to take the

[jira] [Commented] (KAFKA-5949) User Callback Exceptions need to be handled properly

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

[jira] [Updated] (KAFKA-5949) User Callback Exceptions need to be handled properly

[ https://issues.apache.org/jira/browse/KAFKA-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5949: --- Description: In Streams, we allow to register multiple user callbacks. We need to handle

[jira] [Commented] (KAFKA-5793) Tighten up situations where OutOfOrderSequence may be returned

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

[jira] [Commented] (KAFKA-2200) kafkaProducer.send() should not call callback.onCompletion()

[ https://issues.apache.org/jira/browse/KAFKA-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175415#comment-16175415 ] Andy Chambers commented on KAFKA-2200: -- I'd like to do this if nobody else is working on it. >

[jira] [Commented] (KAFKA-2167) ZkUtils updateEphemeralPath JavaDoc (spelling and correctness)

[ https://issues.apache.org/jira/browse/KAFKA-2167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175396#comment-16175396 ] Andy Chambers commented on KAFKA-2167: -- Yeah please close. This is fixed in trunk. > ZkUtils

[jira] [Commented] (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:comment-tabpanel=16175367#comment-16175367 ] Tom Bentley commented on KAFKA-5877: [~lindong] I was merely trying to point out (give that you had

[jira] [Commented] (KAFKA-5856) Add AdminClient.createPartitions()

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

[jira] [Commented] (KAFKA-5956) StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized

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

[jira] [Commented] (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:comment-tabpanel=16175245#comment-16175245 ] Dong Lin commented on KAFKA-5877: - [~tombentley] I may have misunderstood your comment. Are you saying the

[jira] [Issue Comment Deleted] (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: Comment: was deleted (was: [~tombentley] I didn't notice your comment earlier. The issue is fixed with

[jira] [Commented] (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:comment-tabpanel=16175242#comment-16175242 ] Dong Lin commented on KAFKA-5877: - [~tombentley] I didn't notice your comment earlier. The issue is fixed

[jira] [Commented] (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:comment-tabpanel=16175229#comment-16175229 ] Fredrik Vraalsen commented on KAFKA-5877: - It seems we're hitting this bug when reassigning

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175117#comment-16175117 ] Jiangjie Qin commented on KAFKA-5886: - [~guozhang] The patch is still going through review iterations.

[jira] [Commented] (KAFKA-5793) Tighten up situations where OutOfOrderSequence may be returned

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

[jira] [Commented] (KAFKA-5955) Transient failure: AuthorizerIntegrationTest.testTransactionalProducerTopicAuthorizationExceptionInCommit

[ https://issues.apache.org/jira/browse/KAFKA-5955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16175049#comment-16175049 ] Ismael Juma commented on KAFKA-5955: cc [~apurva] [~hachikuji] > Transient failure: >

[jira] [Commented] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest

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

[jira] [Commented] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest

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

[jira] [Commented] (KAFKA-5856) Add AdminClient.createPartitions()

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

[jira] [Created] (KAFKA-5954) Failure in Connect system test: ConnectRestApiTest

Randall Hauch created KAFKA-5954: Summary: Failure in Connect system test: ConnectRestApiTest Key: KAFKA-5954 URL: https://issues.apache.org/jira/browse/KAFKA-5954 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-5947) Handle authentication failures from transactional producer and KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5947. Resolution: Fixed > Handle authentication failures from transactional producer and >

[jira] [Commented] (KAFKA-5947) Handle authentication failures from transactional producer and KafkaAdminClient

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

[jira] [Commented] (KAFKA-5886) Introduce delivery.timeout.ms producer config (KIP-91)

[ https://issues.apache.org/jira/browse/KAFKA-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174687#comment-16174687 ] Guozhang Wang commented on KAFKA-5886: -- [~sutambe] [~becket_qin] What's the current status of this

[jira] [Commented] (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:comment-tabpanel=16174617#comment-16174617 ] ASF GitHub Bot commented on KAFKA-5867: --- GitHub user kkonstantine opened a pull request:

[jira] [Comment Edited] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174490#comment-16174490 ] Jiri Pechanec edited comment on KAFKA-5953 at 9/21/17 9:19 AM: --- Maybe

[jira] [Commented] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

[ https://issues.apache.org/jira/browse/KAFKA-5953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174490#comment-16174490 ] Jiri Pechanec commented on KAFKA-5953: -- Maybe {getResource} method on ClassLoader should be

[jira] [Created] (KAFKA-5953) Connect classloader isolation may be broken for JDBC drivers

Jiri Pechanec created KAFKA-5953: Summary: Connect classloader isolation may be broken for JDBC drivers Key: KAFKA-5953 URL: https://issues.apache.org/jira/browse/KAFKA-5953 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-5922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5922. -- Resolution: Fixed Issue resolved by pull request 3902

[jira] [Commented] (KAFKA-5950) AdminClient should retry based on returned error codes

[ https://issues.apache.org/jira/browse/KAFKA-5950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174368#comment-16174368 ] Andrey Dyachkov commented on KAFKA-5950: [~ijuma] if it is ready to take in work, I would like to

[jira] [Created] (KAFKA-5952) Refactor Consumer Fetcher metrics

James Cheng created KAFKA-5952: -- Summary: Refactor Consumer Fetcher metrics Key: KAFKA-5952 URL: https://issues.apache.org/jira/browse/KAFKA-5952 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

[ https://issues.apache.org/jira/browse/KAFKA-5951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16174346#comment-16174346 ] James Cheng commented on KAFKA-5951: [~guozhang] [~ijuma], I'd like to get this into 1.0.0, if

[jira] [Created] (KAFKA-5951) Autogenerate Producer RecordAccumulator metrics

James Cheng created KAFKA-5951: -- Summary: Autogenerate Producer RecordAccumulator metrics Key: KAFKA-5951 URL: https://issues.apache.org/jira/browse/KAFKA-5951 Project: Kafka Issue Type: