[jira] [Commented] (KAFKA-4595) Controller send thread can't stop when broker change listener event trigger for dead brokers

[ https://issues.apache.org/jira/browse/KAFKA-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823594#comment-15823594 ] huxi commented on KAFKA-4595: - [~pengwei] I don't think it's doable since it would leave incon

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823679#comment-15823679 ] Alberto Forti commented on KAFKA-4629: -- Hi Huxi, I've noticed this behaviour in our

[jira] [Comment Edited] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823329#comment-15823329 ] huxi edited comment on KAFKA-4629 at 1/16/17 9:36 AM: -- [~alberto.fo..

[jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823702#comment-15823702 ] darmagan commented on KAFKA-3992: - I have tried both scenarios, with and without set clien

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823725#comment-15823725 ] Ismael Juma commented on KAFKA-4629: There are 2 points here: 1. What's the best way

[jira] [Commented] (KAFKA-3586) Quotas do not revert to default values when override config is deleted

[ https://issues.apache.org/jira/browse/KAFKA-3586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823738#comment-15823738 ] ASF GitHub Bot commented on KAFKA-3586: --- Github user rajinisivaram closed the pull r

[GitHub] kafka pull request #1238: KAFKA-3586: Revert to default quota when client qu...

Github user rajinisivaram closed the pull request at: https://github.com/apache/kafka/pull/1238 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] kafka pull request #738: KAFKA-3070: Use IBM Kerberos module for SASL tests ...

Github user rajinisivaram closed the pull request at: https://github.com/apache/kafka/pull/738 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature i

[jira] [Commented] (KAFKA-3070) SASL unit tests dont work with IBM JDK

[ https://issues.apache.org/jira/browse/KAFKA-3070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823742#comment-15823742 ] ASF GitHub Bot commented on KAFKA-3070: --- Github user rajinisivaram closed the pull r

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823745#comment-15823745 ] Ismael Juma commented on KAFKA-4421: [~ewencp], since [~guozhang] did 0.10.1.1 with Sc

[jira] [Updated] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4614: --- Reviewer: Jun Rao > Long GC pause harming broker performance which is caused by mmap objects > create

[jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823762#comment-15823762 ] Ismael Juma commented on KAFKA-4614: [~ewencp], sure. I assigned [~junrao] as the revi

[GitHub] kafka pull request #2384: KAFKA-4622: Consumer should handle group authoriza...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2384 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

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

[jira] [Resolved] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

[ https://issues.apache.org/jira/browse/KAFKA-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4622. Resolution: Fixed Issue resolved by pull request 2384 [https://github.com/apache/kafka/pull/2384] >

[jira] [Updated] (KAFKA-4596) KIP-73 rebalance throttling breaks on plans for specific partitions

[ https://issues.apache.org/jira/browse/KAFKA-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4596: --- Assignee: Ben Stopford > KIP-73 rebalance throttling breaks on plans for specific partitions > ---

[jira] [Commented] (KAFKA-4596) KIP-73 rebalance throttling breaks on plans for specific partitions

[ https://issues.apache.org/jira/browse/KAFKA-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823797#comment-15823797 ] Ismael Juma commented on KAFKA-4596: [~ewencp], I'm tentatively assigning this to Ben

[jira] [Commented] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823816#comment-15823816 ] Eno Thereska commented on KAFKA-4563: - [~ewencp] This is lower priority, however shoul

[jira] [Updated] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4563: Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > State transitions error PARTITIONS_

[GitHub] kafka pull request #2385: MINOR: remove unused constructor param from Proces...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2385 MINOR: remove unused constructor param from ProcessorStateManager Remove applicationId parameter as it is no longer used. You can merge this pull request into a Git repository by running: $ git pu

[GitHub] kafka pull request #2359: KAFKA-3452: follow up - fix state store restoratio...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/2359 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enable

[jira] [Commented] (KAFKA-3452) Support session windows

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

[jira] [Updated] (KAFKA-4588) QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable is occasionally failing on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4588: -- Status: Patch Available (was: In Progress) > QueryableStateIntegrationTest.shouldNotMakeStoreAvailableU

[jira] [Work started] (KAFKA-4588) QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable is occasionally failing on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4588 started by Damian Guy. - > QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable > i

[jira] [Commented] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823855#comment-15823855 ] Ismael Juma commented on KAFKA-4450: Maybe we should rename TRUNK to CURRENT_BRANCH as

[jira] [Assigned] (KAFKA-4578) Upgrade notes for 0.10.2.0

[ https://issues.apache.org/jira/browse/KAFKA-4578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4578: -- Assignee: Ismael Juma > Upgrade notes for 0.10.2.0 > -- > >

[jira] [Updated] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

[ https://issues.apache.org/jira/browse/KAFKA-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4630: --- Priority: Blocker (was: Major) > Implement RecordTooLargeException when communicating with pre-KIP-74

[jira] [Work started] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4617 started by Dhwani Katagade. -- > gradle-generated core eclipse project has incorrect source folder structure

[jira] [Updated] (KAFKA-4635) Client Compatibility follow-up

[ https://issues.apache.org/jira/browse/KAFKA-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4635: --- Fix Version/s: 0.10.2.0 > Client Compatibility follow-up > -- > >

[jira] [Created] (KAFKA-4635) Client Compatibility follow-up

Ismael Juma created KAFKA-4635: -- Summary: Client Compatibility follow-up Key: KAFKA-4635 URL: https://issues.apache.org/jira/browse/KAFKA-4635 Project: Kafka Issue Type: Sub-task Rep

[jira] [Updated] (KAFKA-4635) Client Compatibility follow-up

[ https://issues.apache.org/jira/browse/KAFKA-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4635: --- Assignee: Colin P. McCabe > Client Compatibility follow-up > -- > >

[jira] [Updated] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhwani Katagade updated KAFKA-4617: --- Labels: build (was: ) Reviewer: Edoardo Comar Status: Patch Available (was: In Pr

[jira] [Work stopped] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4604 stopped by Dhwani Katagade. -- > Gradle Eclipse plugin creates projects for non project subfolders > ---

[jira] [Commented] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

[ https://issues.apache.org/jira/browse/KAFKA-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823928#comment-15823928 ] Ismael Juma commented on KAFKA-4630: [~ewencp], the consequence would be that if a pre

[jira] [Updated] (KAFKA-4635) Client Compatibility follow-up

[ https://issues.apache.org/jira/browse/KAFKA-4635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4635: --- Description: I collected a number of improvements that I think would be good to do before the release

[jira] [Commented] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

[ https://issues.apache.org/jira/browse/KAFKA-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823930#comment-15823930 ] Ismael Juma commented on KAFKA-4630: I changed the priority to "Blocker" since Colin w

Build failed in Jenkins: kafka-trunk-jdk8 #1182

See Changes: [ismael] KAFKA-4622; Consumer should handle group authorization errors in offset -- [...truncated 32393 lines...] kafka.integration.SaslPlaintextTopicMetadataTest > testIsrAfterBr

[jira] [Comment Edited] (KAFKA-4501) Support Java 9

[ https://issues.apache.org/jira/browse/KAFKA-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824085#comment-15824085 ] Ismael Juma edited comment on KAFKA-4501 at 1/16/17 2:42 PM: -

[jira] [Commented] (KAFKA-4501) Support Java 9

[ https://issues.apache.org/jira/browse/KAFKA-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824085#comment-15824085 ] Ismael Juma commented on KAFKA-4501: Sounds good to me [~ewencp]. A couple of things i

[jira] [Created] (KAFKA-4636) Per listener security settings (KIP-103)

Ismael Juma created KAFKA-4636: -- Summary: Per listener security settings (KIP-103) Key: KAFKA-4636 URL: https://issues.apache.org/jira/browse/KAFKA-4636 Project: Kafka Issue Type: Bug

[jira] [Work started] (KAFKA-4636) Per listener security settings (KIP-103)

[ https://issues.apache.org/jira/browse/KAFKA-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4636 started by Ismael Juma. -- > Per listener security settings (KIP-103) >

[jira] [Updated] (KAFKA-4636) Per listener security settings (KIP-103)

[ https://issues.apache.org/jira/browse/KAFKA-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4636: --- Labels: kip (was: ) > Per listener security settings (KIP-103) >

[jira] [Assigned] (KAFKA-4636) Per listener security settings (KIP-103)

[ https://issues.apache.org/jira/browse/KAFKA-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4636: -- Assignee: Ismael Juma > Per listener security settings (KIP-103) >

[jira] [Updated] (KAFKA-4636) Per listener security setting overrides (KIP-103)

[ https://issues.apache.org/jira/browse/KAFKA-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4636: --- Summary: Per listener security setting overrides (KIP-103) (was: Per listener security settings (KIP-

[jira] [Updated] (KAFKA-4636) Per listener security setting overrides (KIP-103)

[ https://issues.apache.org/jira/browse/KAFKA-4636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4636: --- Issue Type: Improvement (was: Bug) > Per listener security setting overrides (KIP-103) >

[jira] [Created] (KAFKA-4637) Update system test(s) to use multiple listeners for the same security protocol

Ismael Juma created KAFKA-4637: -- Summary: Update system test(s) to use multiple listeners for the same security protocol Key: KAFKA-4637 URL: https://issues.apache.org/jira/browse/KAFKA-4637 Project: Kaf

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824221#comment-15824221 ] Alberto Forti commented on KAFKA-4629: -- Just an update regarding [~huxi_2b] request.

[DISCUSS] KIP-114: KTable materialization and improved semantics

Hello, We created "KIP-114: KTable materialization and improved semantics" to solidify the KTable semantics in Kafka Streams: https://cwiki.apache.org/confluence/display/KAFKA/KIP-114%3A+KTable+materialization+and+improved+semantics

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Thanks for the KIP, Eno. It seems reasonable on first inspection although others more familiar with Streams may have more to say. :) With regards to "log compaction based on timestamps", it may make sense to do that as its own KIP as interested parties may miss it if it's inside a Streams KIP. It w

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

That's a good idea. I'll keep KIP-114 for the streams changes only and do a new KIP soon for the log compaction as both are independent improvements. I'm removing 2 paragraphs from KIP-114, but otherwise it's still good to discuss on this thread. Thanks Eno > On 16 Jan 2017, at 17:12, Ismael Ju

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Eno, Thanks for the KIP. Some comments: 1. I'd probably rename materialized to materialize. 2. I don't think the addition of the new Log compaction mechanism is necessary for this KIP, i.e, the KIP is useful without it. Maybe that should be a different KIP? 3. What will happen w

[jira] [Commented] (KAFKA-2410) Implement "Auto Topic Creation" client side and remove support from Broker side

[ https://issues.apache.org/jira/browse/KAFKA-2410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824382#comment-15824382 ] Jeff Widman commented on KAFKA-2410: I strongly support removing it from the Broker.

[jira] [Assigned] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sreepathi Prasanna reassigned KAFKA-1313: - Assignee: Sreepathi Prasanna > Support adding replicas to existing topic partitio

[GitHub] kafka pull request #2346: KAFKA-4619: Dissallow to output records with unkno...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2346 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Updated] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

[ https://issues.apache.org/jira/browse/KAFKA-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4619: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[jira] [Commented] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

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

[jira] [Created] (KAFKA-4638) Outdated and misleading link in section "End-to-end Batch Compression"

Vincent Tieleman created KAFKA-4638: --- Summary: Outdated and misleading link in section "End-to-end Batch Compression" Key: KAFKA-4638 URL: https://issues.apache.org/jira/browse/KAFKA-4638 Project: K

[jira] [Resolved] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4604. -- Resolution: Duplicate > Gradle Eclipse plugin creates projects for non project subfolders >

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824470#comment-15824470 ] Guozhang Wang commented on KAFKA-4421: -- I added a one liner note on the release proce

[jira] [Commented] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824483#comment-15824483 ] Ewen Cheslack-Postava commented on KAFKA-3992: -- [~darmag] That is a bug in th

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824484#comment-15824484 ] Ismael Juma commented on KAFKA-4421: @guozhangwang, you didn't change JAVA_HOME to poi

[jira] [Comment Edited] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824484#comment-15824484 ] Ismael Juma edited comment on KAFKA-4421 at 1/16/17 7:38 PM: -

[GitHub] kafka pull request #2385: MINOR: remove unused constructor param from Proces...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2385 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824512#comment-15824512 ] Guozhang Wang commented on KAFKA-4421: -- [~ijuma] Ah yes, I did. This needs to be writ

Re: 0.10.2.0 release planning

Thanks to everyone that helped with development and review of the KIPs. We got nearly everything we aimed for in! We'll give the release a couple of more weeks to fully bake and stabilize, focusing mostly on getting bug fixes and improved tests into the release branch. I've cut the 0.10.2 release

[jira] [Updated] (KAFKA-4514) Add Codec for ZStandard Compression

[ https://issues.apache.org/jira/browse/KAFKA-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4514: - Assignee: Lee Dongjin > Add Codec for ZStandard Compression >

[jira] [Updated] (KAFKA-4632) Kafka Connect WorkerSinkTask.closePartitions doesn't handle WakeupException

[ https://issues.apache.org/jira/browse/KAFKA-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4632: - Component/s: KafkaConnect > Kafka Connect WorkerSinkTask.closePartitions doesn't h

[jira] [Updated] (KAFKA-4182) Move the change logger out of RocksDB stores

[ https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4182: - Summary: Move the change logger out of RocksDB stores (was: Move the change logger our of RocksDB

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824648#comment-15824648 ] Eno Thereska commented on KAFKA-4468: - Hi [~bbejeck], are you still interested in this

[jira] [Created] (KAFKA-4639) Kafka Streams metrics are undocumented

Elias Levy created KAFKA-4639: - Summary: Kafka Streams metrics are undocumented Key: KAFKA-4639 URL: https://issues.apache.org/jira/browse/KAFKA-4639 Project: Kafka Issue Type: Bug Comp

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824683#comment-15824683 ] Bill Bejeck commented on KAFKA-4468: Hi, Eno - I was, but for a couple of reasons I un

Jenkins build is back to normal : kafka-trunk-jdk8 #1183

See

[jira] [Updated] (KAFKA-4639) Kafka Streams metrics are undocumented

[ https://issues.apache.org/jira/browse/KAFKA-4639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4639: - Assignee: Eno Thereska > Kafka Streams metrics are undocumented >

[jira] [Commented] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15824788#comment-15824788 ] Edoardo Comar commented on KAFKA-4617: -- [~dhwanikatagade] thanks for the patch, The

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825006#comment-15825006 ] Jiangjie Qin commented on KAFKA-4401: - [~ewencp] I think it is a good suggestion. Tech

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825545#comment-15825545 ] huxi commented on KAFKA-4629: - Thanks for [~alberto.fo...@natwestmarkets.com]'s response. Afte

[jira] [Comment Edited] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825545#comment-15825545 ] huxi edited comment on KAFKA-4629 at 1/17/17 6:41 AM: -- Thanks for [~a

[jira] [Comment Edited] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15825545#comment-15825545 ] huxi edited comment on KAFKA-4629 at 1/17/17 6:48 AM: -- Thanks for [~a