[jira] [Created] (KAFKA-9114) Kafka broker fails to establish secure zookeeper connection via SSL.

Gangadhar Balikai created KAFKA-9114: Summary: Kafka broker fails to establish secure zookeeper connection via SSL. Key: KAFKA-9114 URL: https://issues.apache.org/jira/browse/KAFKA-9114 Project:

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

[ https://issues.apache.org/jira/browse/KAFKA-8733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana updated KAFKA-8733: -- Description: We found offline partitions issue multiple times on some of the hosts in our

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961780#comment-16961780 ] Bruno Cadonna commented on KAFKA-9088: -- [~ableegoldman] I do not completely follow here, also

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961820#comment-16961820 ] Bruno Cadonna commented on KAFKA-8630: -- I also run into the {{ClassCastException}} during

[jira] [Created] (KAFKA-9109) Get Rid of Cast from ProcessorContext to InternalProcessorContext

Bruno Cadonna created KAFKA-9109: Summary: Get Rid of Cast from ProcessorContext to InternalProcessorContext Key: KAFKA-9109 URL: https://issues.apache.org/jira/browse/KAFKA-9109 Project: Kafka

[jira] [Commented] (KAFKA-6689) Kafka not release .deleted file.

[ https://issues.apache.org/jira/browse/KAFKA-6689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961959#comment-16961959 ] Krithika Balu commented on KAFKA-6689: -- I'll look into the issue and try to debug. > Kafka not

[jira] [Commented] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961918#comment-16961918 ] Stanislav Kozlovski commented on KAFKA-8010: I also hit this issue and verified using square

[jira] [Commented] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

[ https://issues.apache.org/jira/browse/KAFKA-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961829#comment-16961829 ] Bruno Cadonna commented on KAFKA-8977: -- I see your point. Isn't it possible to come up with a common

[jira] [Commented] (KAFKA-8353) org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms after enabling SASL PLAINTEXT authentication

[ https://issues.apache.org/jira/browse/KAFKA-8353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961881#comment-16961881 ] Fangwei Duan commented on KAFKA-8353: - I had this problem too. and finally it turn out the reason is

[jira] [Assigned] (KAFKA-9077) System Test Failure: StreamsSimpleBenchmarkTest

[ https://issues.apache.org/jira/browse/KAFKA-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-9077: Assignee: Bruno Cadonna > System Test Failure: StreamsSimpleBenchmarkTest >

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961786#comment-16961786 ] Bruno Cadonna commented on KAFKA-9088: -- [~ableegoldman] Ah OK, I now saw the related issue under

[jira] [Created] (KAFKA-9110) Improve efficiency of disk reads when TLS is enabled

Ismael Juma created KAFKA-9110: -- Summary: Improve efficiency of disk reads when TLS is enabled Key: KAFKA-9110 URL: https://issues.apache.org/jira/browse/KAFKA-9110 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-9110) Improve efficiency of disk reads when TLS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-9110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9110: --- Description: We currently do 8k reads and do unnecessary copies and allocations in every read.

[jira] [Updated] (KAFKA-9110) Improve efficiency of disk reads when TLS is enabled

[ https://issues.apache.org/jira/browse/KAFKA-9110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-9110: --- Fix Version/s: 2.5.0 > Improve efficiency of disk reads when TLS is enabled >

[jira] [Commented] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

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

[jira] [Commented] (KAFKA-9069) Flaky Test AdminClientIntegrationTest.testCreatePartitions

[ https://issues.apache.org/jira/browse/KAFKA-9069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962318#comment-16962318 ] Bruno Cadonna commented on KAFKA-9069: --

[jira] [Commented] (KAFKA-9077) System Test Failure: StreamsSimpleBenchmarkTest

[ https://issues.apache.org/jira/browse/KAFKA-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962293#comment-16962293 ] ASF GitHub Bot commented on KAFKA-9077: --- cadonna commented on pull request #7610: KAFKA-9077: Fix

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962249#comment-16962249 ] Matthias J. Sax commented on KAFKA-8677:

[jira] [Created] (KAFKA-9111) Incorrect project category in DOAP file, breaking projects.apache.org category listing

Nick Burch created KAFKA-9111: - Summary: Incorrect project category in DOAP file, breaking projects.apache.org category listing Key: KAFKA-9111 URL: https://issues.apache.org/jira/browse/KAFKA-9111

[jira] [Commented] (KAFKA-9059) Implement ReassignmentMaxLag

[ https://issues.apache.org/jira/browse/KAFKA-9059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962152#comment-16962152 ] ASF GitHub Bot commented on KAFKA-9059: --- viktorsomogyi commented on pull request #7609: KAFKA-9059:

[jira] [Updated] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8677: - Description: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6325/console]   *18:43:39*

[jira] [Commented] (KAFKA-9077) System Test Failure: StreamsSimpleBenchmarkTest

[ https://issues.apache.org/jira/browse/KAFKA-9077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962367#comment-16962367 ] ASF GitHub Bot commented on KAFKA-9077: --- bbejeck commented on pull request #7610: KAFKA-9077: Fix

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962360#comment-16962360 ] Sophie Blee-Goldman commented on KAFKA-9088: Whoops, thanks for pointing that out. Went back

[jira] [Assigned] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8630: -- Assignee: Sophie Blee-Goldman > Unit testing a streams processor with a

[jira] [Resolved] (KAFKA-9077) System Test Failure: StreamsSimpleBenchmarkTest

[jira] [Assigned] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman reassigned KAFKA-8630: -- Assignee: (was: Sophie Blee-Goldman) > Unit testing a streams processor

[jira] [Comment Edited] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16961475#comment-16961475 ] Sophie Blee-Goldman edited comment on KAFKA-9088 at 10/29/19 7:55 PM:

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962413#comment-16962413 ] Sophie Blee-Goldman commented on KAFKA-8630: That's fair, I agree that would be the ideal

[jira] [Commented] (KAFKA-8630) Unit testing a streams processor with a WindowStore throws a ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962448#comment-16962448 ] Bruno Cadonna commented on KAFKA-8630: -- Agreed > Unit testing a streams processor with a

[jira] [Created] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

Boyang Chen created KAFKA-9112: -- Summary: Combine streams `onAssignment` with `partitionsAssigned` task creation Key: KAFKA-9112 URL: https://issues.apache.org/jira/browse/KAFKA-9112 Project: Kafka

[jira] [Assigned] (KAFKA-9040) Implement --all option for describing configs

[ https://issues.apache.org/jira/browse/KAFKA-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raymond Ng reassigned KAFKA-9040: - Assignee: Raymond Ng (was: Jason Gustafson) > Implement --all option for describing configs >

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962541#comment-16962541 ] Ashish Surana commented on KAFKA-6555: -- [~vinoth] I worked on it earlier like an year back and since

[jira] [Commented] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962498#comment-16962498 ] Sophie Blee-Goldman commented on KAFKA-9112: I agree with this ticket 100% and had the same

[jira] [Created] (KAFKA-9113) Clean up task management

Sophie Blee-Goldman created KAFKA-9113: -- Summary: Clean up task management Key: KAFKA-9113 URL: https://issues.apache.org/jira/browse/KAFKA-9113 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9112: --- Component/s: streams > Combine streams `onAssignment` with `partitionsAssigned` task creation >

[jira] [Updated] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9112: --- Component/s: (was: consumer) > Combine streams `onAssignment` with

[jira] [Updated] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9112: --- Component/s: consumer > Combine streams `onAssignment` with `partitionsAssigned`

[jira] [Commented] (KAFKA-9025) ZkSecurityMigrator not working with zookeeper chroot

[ https://issues.apache.org/jira/browse/KAFKA-9025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962659#comment-16962659 ] huxihx commented on KAFKA-9025: --- [~lmairbus] You should explicitly specify the chroot when running 

[jira] [Comment Edited] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962498#comment-16962498 ] Sophie Blee-Goldman edited comment on KAFKA-9112 at 10/30/19 3:59 AM:

[jira] [Commented] (KAFKA-9112) Combine streams `onAssignment` with `partitionsAssigned` task creation

[ https://issues.apache.org/jira/browse/KAFKA-9112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962667#comment-16962667 ] Sophie Blee-Goldman commented on KAFKA-9112: The thoughts above are obviously way beyond the

[jira] [Commented] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

[ https://issues.apache.org/jira/browse/KAFKA-8939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16962668#comment-16962668 ] Sophie Blee-Goldman commented on KAFKA-8939: h3. Stacktrace java.lang.AssertionError:

[jira] [Updated] (KAFKA-9113) Clean up task management

[ https://issues.apache.org/jira/browse/KAFKA-9113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-9113: --- Component/s: streams > Clean up task management > > >

[jira] [Commented] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

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

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

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

[jira] [Resolved] (KAFKA-8972) KafkaConsumer.unsubscribe could leave inconsistent user rebalance callback state

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-8972. Resolution: Fixed Nice work guys! > KafkaConsumer.unsubscribe could leave