[jira] [Commented] (KAFKA-8733) Offline partitions occur when leader's disk is slow in reads while responding to follower fetch requests.

2020-10-24 Thread GEORGE LI (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220243#comment-17220243 ] GEORGE LI commented on KAFKA-8733: -- for lossy clusters, setting unclean.leader.election

[GitHub] [kafka] RamanVerma commented on a change in pull request #9364: KAFKA-10471 Mark broker crash during log loading as unclean shutdown

2020-10-24 Thread GitBox
RamanVerma commented on a change in pull request #9364: URL: https://github.com/apache/kafka/pull/9364#discussion_r511545890 ## File path: core/src/test/scala/unit/kafka/log/LogTest.scala ## @@ -1257,7 +1328,7 @@ class LogTest { log.close() // After reloading log, p

[GitHub] [kafka] RamanVerma commented on a change in pull request #9364: KAFKA-10471 Mark broker crash during log loading as unclean shutdown

2020-10-24 Thread GitBox
RamanVerma commented on a change in pull request #9364: URL: https://github.com/apache/kafka/pull/9364#discussion_r511545712 ## File path: core/src/test/scala/unit/kafka/log/LogTest.scala ## @@ -2131,12 +2202,12 @@ class LogTest { assertEquals("Should have same number of

[GitHub] [kafka] chia7712 commented on pull request #9374: MINOR: Fix NPE in KafkaAdminClient.describeUserScramCredentials

2020-10-24 Thread GitBox
chia7712 commented on pull request #9374: URL: https://github.com/apache/kafka/pull/9374#issuecomment-716090509 We can merge this patch so as to avoid making a release with (known) unavailable Public APIs. Honoring the protocol (null handle) on server-side can be a follow-up. Just my two c

[jira] [Commented] (KAFKA-7870) Error sending fetch request (sessionId=1578860481, epoch=INITIAL) to node 2: java.io.IOException: Connection to 2 was disconnected before the response was read.

2020-10-24 Thread Eran Levy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220237#comment-17220237 ] Eran Levy commented on KAFKA-7870: -- Experiencing that with 2.6.0 {"timestamp":"2020-10-

[GitHub] [kafka] rondagostino commented on pull request #9374: MINOR: Fix NPE in KafkaAdminClient.describeUserScramCredentials

2020-10-24 Thread GitBox
rondagostino commented on pull request #9374: URL: https://github.com/apache/kafka/pull/9374#issuecomment-716065197 This isn’t a regression, so I don’t think it is a blocker. NPE would only occur if someone were to code against the new API. The kafka-configs.sh CLI works fine because it

[GitHub] [kafka] rondagostino edited a comment on pull request #9374: MINOR: Fix NPE in KafkaAdminClient.describeUserScramCredentials

2020-10-24 Thread GitBox
rondagostino edited a comment on pull request #9374: URL: https://github.com/apache/kafka/pull/9374#issuecomment-716065197 This isn’t a regression, so I don’t think it is a blocker. NPE would only occur if someone were to code against the new API. The kafka-configs.sh CLI works fine beca

[GitHub] [kafka] dajac commented on pull request #9374: MINOR: Fix NPE in KafkaAdminClient.describeUserScramCredentials

2020-10-24 Thread GitBox
dajac commented on pull request #9374: URL: https://github.com/apache/kafka/pull/9374#issuecomment-716061853 @rondagostino Is this issue a blocker for 2.7? cc @bbejeck This is an automated message from the Apache Git Service

[GitHub] [kafka] afalko commented on pull request #8794: KAFKA-10092: Remove unused code branches in NioEchoServer

2020-10-24 Thread GitBox
afalko commented on pull request #8794: URL: https://github.com/apache/kafka/pull/8794#issuecomment-716058925 > @afalko Could you rebase PR to trigger QA? Thanks! Looks like it partially passed. I'll merge master against and see if it does better. -

[GitHub] [kafka] omkreddy commented on pull request #9496: MINOR: fix error in quota_test.py system tests

2020-10-24 Thread GitBox
omkreddy commented on pull request #9496: URL: https://github.com/apache/kafka/pull/9496#issuecomment-716048849 cc @rondagostino This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [kafka] omkreddy opened a new pull request #9496: MINOR: fix error in quota_test.py system tests

2020-10-24 Thread GitBox
omkreddy opened a new pull request #9496: URL: https://github.com/apache/kafka/pull/9496 ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrad

[GitHub] [kafka] omkreddy commented on pull request #9480: KAFKA-10592: Fix vagrant for a system tests with python3

2020-10-24 Thread GitBox
omkreddy commented on pull request #9480: URL: https://github.com/apache/kafka/pull/9480#issuecomment-716045146 Merging to trunk and 2.7 This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [kafka] omkreddy closed pull request #9480: KAFKA-10592: Fix vagrant for a system tests with python3

2020-10-24 Thread GitBox
omkreddy closed pull request #9480: URL: https://github.com/apache/kafka/pull/9480 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[jira] [Updated] (KAFKA-10641) ACL Command hangs with SSL as not existing with proper error code

2020-10-24 Thread Senthilnathan Muthusamy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Senthilnathan Muthusamy updated KAFKA-10641: Summary: ACL Command hangs with SSL as not existing with proper error code

[GitHub] [kafka] senthilm-ms opened a new pull request #9495: KAFKA-10642: Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

2020-10-24 Thread GitBox
senthilm-ms opened a new pull request #9495: URL: https://github.com/apache/kafka/pull/9495 If there is any exception occurred in the custom implementation of client trust verification (i.e. using security.provider), the inner exception is suppressed or hidden and not logged to the log fil

[jira] [Created] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

2020-10-24 Thread Senthilnathan Muthusamy (Jira)
Senthilnathan Muthusamy created KAFKA-10642: --- Summary: Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension Key: KAFKA-10642 URL: https://issues.apache.

[GitHub] [kafka] joshuagrisham commented on pull request #9493: KAFKA-10640: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native

2020-10-24 Thread GitBox
joshuagrisham commented on pull request #9493: URL: https://github.com/apache/kafka/pull/9493#issuecomment-716041356 I cleaned up most of the checkstyle issues before creating this new PR but it is still failing in 3 places due to CyclomaticComplexity failure. This is basically because th

[GitHub] [kafka] senthilm-ms commented on pull request #9494: KAFKA-10641: ACL Command Exit properly always with error code

2020-10-24 Thread GitBox
senthilm-ms commented on pull request #9494: URL: https://github.com/apache/kafka/pull/9494#issuecomment-716040837 @junrao @mjsax @guozhangwang This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [kafka] senthilm-ms opened a new pull request #9494: KAFKA-10641: ACL Command Exit properly always with error code

2020-10-24 Thread GitBox
senthilm-ms opened a new pull request #9494: URL: https://github.com/apache/kafka/pull/9494 When using ACL Command with SSL mode, the process is not terminating after successful ACL operation. This is an automated message fr

[jira] [Created] (KAFKA-10641) ACL Command hands with SSL as not existing with proper error code

2020-10-24 Thread Senthilnathan Muthusamy (Jira)
Senthilnathan Muthusamy created KAFKA-10641: --- Summary: ACL Command hands with SSL as not existing with proper error code Key: KAFKA-10641 URL: https://issues.apache.org/jira/browse/KAFKA-10641

[GitHub] [kafka] joshuagrisham commented on pull request #9470: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON stri

2020-10-24 Thread GitBox
joshuagrisham commented on pull request #9470: URL: https://github.com/apache/kafka/pull/9470#issuecomment-716030144 Closing this PR in favor of #9493 -- I had to do some cleanup and move this out of my repo's trunk branch and into its own branch. -

[GitHub] [kafka] joshuagrisham closed pull request #9470: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON string.

2020-10-24 Thread GitBox
joshuagrisham closed pull request #9470: URL: https://github.com/apache/kafka/pull/9470 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [kafka] joshuagrisham opened a new pull request #9492: KAFKA-10627: Added support for Connect TimestampConverter to convert multiple fields using a comma-separated list, and changed the Strin

2020-10-24 Thread GitBox
joshuagrisham opened a new pull request #9492: URL: https://github.com/apache/kafka/pull/9492 I have made an update to **TimestampConverter** Connect transform to address the main issues that I logged in [KAFKA-10627](https://issues.apache.org/jira/browse/KAFKA-10627). I realized th

[jira] [Commented] (KAFKA-8733) Offline partitions occur when leader's disk is slow in reads while responding to follower fetch requests.

2020-10-24 Thread Ming Liu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17220139#comment-17220139 ] Ming Liu commented on KAFKA-8733: - One observation is after moving to 2.5 (so  _[replica.

[GitHub] [kafka] omkreddy closed pull request #9490: Pin ducktape to version 0.7.10

2020-10-24 Thread GitBox
omkreddy closed pull request #9490: URL: https://github.com/apache/kafka/pull/9490 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to t

[GitHub] [kafka] omkreddy commented on pull request #9490: Pin ducktape to version 0.7.10

2020-10-24 Thread GitBox
omkreddy commented on pull request #9490: URL: https://github.com/apache/kafka/pull/9490#issuecomment-715967601 Merging to 2.6 and below. This is an automated message from the Apache Git Service. To respond to the message, pl

[GitHub] [kafka] omkreddy commented on pull request #9490: Pin ducktape to version 0.7.10

2020-10-24 Thread GitBox
omkreddy commented on pull request #9490: URL: https://github.com/apache/kafka/pull/9490#issuecomment-715967307 test results: http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-10-24--001.1603547932--stan-confluent--ducktape-710-26--c39b5894d/report.ht

[jira] [Created] (KAFKA-10640) Connect Cast and ReplaceField transforms only support top-level fields and Cast does not support complex types.

2020-10-24 Thread Joshua Grisham (Jira)
Joshua Grisham created KAFKA-10640: -- Summary: Connect Cast and ReplaceField transforms only support top-level fields and Cast does not support complex types. Key: KAFKA-10640 URL: https://issues.apache.org/jira/b