[jira] [Created] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

Damian Guy created KAFKA-5095: - Summary: ThreadCacheTest.cacheOverheadsSmallValues fails intermittently Key: KAFKA-5095 URL: https://issues.apache.org/jira/browse/KAFKA-5095 Project: Kafka Issu

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

See Changes: [ismael] MINOR: Update dependencies for 0.11 -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (ub

[GitHub] kafka pull request #2872: MINOR: Update dependencies for 0.11

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2872 --- 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] [Assigned] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska reassigned KAFKA-5095: --- Assignee: Eno Thereska > ThreadCacheTest.cacheOverheadsSmallValues fails intermittently > --

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

See -- Started by user ijuma [EnvInject] - Loading node environment variables. Building remotely on ubuntu-eu2 (ubuntu trusty) in workspace

[GitHub] kafka pull request #2845: KAFKA-4814: Enable ZK ACLs only when zookeeper.set...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2845 --- 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] [Assigned] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-5049: -- Assignee: anugrah > Chroot check should be done for each ZkUtils instance > ---

[jira] [Commented] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl

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

[GitHub] kafka pull request #2876: HOTFIX: guard against unassigned partitions

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2876 HOTFIX: guard against unassigned partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4755-fetcher-only Alter

[jira] [Resolved] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl

[ https://issues.apache.org/jira/browse/KAFKA-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4814. Resolution: Fixed > ZookeeperLeaderElector not respecting zookeeper.set.acl > --

[jira] [Resolved] (KAFKA-5049) Chroot check should be done for each ZkUtils instance

[ https://issues.apache.org/jira/browse/KAFKA-5049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5049. Resolution: Fixed > Chroot check should be done for each ZkUtils instance >

[GitHub] kafka pull request #2877: KAFKA-5095: Adjust accepted overhead

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2877 KAFKA-5095: Adjust accepted overhead You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5095-cacheOverheads Alternativ

[jira] [Commented] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976372#comment-15976372 ] ASF GitHub Bot commented on KAFKA-5095: --- GitHub user enothereska opened a pull reque

[jira] [Work started] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5095 started by Eno Thereska. --- > ThreadCacheTest.cacheOverheadsSmallValues fails intermittently > ---

[jira] [Commented] (KAFKA-5089) JAR mismatch in KafkaConnect leads to NoSuchMethodError

[ https://issues.apache.org/jira/browse/KAFKA-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976381#comment-15976381 ] Christoph Körner commented on KAFKA-5089: - Thanks for the quick reply. I guess it

[jira] [Updated] (KAFKA-5089) JAR mismatch in KafkaConnect leads to NoSuchMethodError in HDP 2.6

[ https://issues.apache.org/jira/browse/KAFKA-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christoph Körner updated KAFKA-5089: Summary: JAR mismatch in KafkaConnect leads to NoSuchMethodError in HDP 2.6 (was: JAR misma

[jira] [Commented] (KAFKA-4814) ZookeeperLeaderElector not respecting zookeeper.set.acl

[ https://issues.apache.org/jira/browse/KAFKA-4814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976432#comment-15976432 ] Balint Molnar commented on KAFKA-4814: -- Thanks [~rsivaram], helping me out with this

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

See

[jira] [Assigned] (KAFKA-5094) Censor SCRAM config change logging

[ https://issues.apache.org/jira/browse/KAFKA-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram reassigned KAFKA-5094: - Assignee: Rajini Sivaram > Censor SCRAM config change logging > -

[GitHub] kafka pull request #2878: KAFKA-3070: SASL unit tests dont work with IBM JDK

GitHub user mimaison opened a pull request: https://github.com/apache/kafka/pull/2878 KAFKA-3070: SASL unit tests dont work with IBM JDK Use IBM Kerberos module for SASL tests if running on IBM JDK Developed with @edoardocomar Based on https://github.com/apache/kafka/pul

[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=15976496#comment-15976496 ] ASF GitHub Bot commented on KAFKA-3070: --- GitHub user mimaison opened a pull request:

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Hi Stephane, Thanks for the KIP. Overall it looks ok, though i think the builder should enforce the required parameters by supplying them via the constructor, i.e, public ProducerRecordBuilder(String topic, V value) You can then remove the withValue and withTopic methods I also think withForce

[GitHub] kafka pull request #2879: KAFKA-5094: Replace SCRAM credentials in broker lo...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/2879 KAFKA-5094: Replace SCRAM credentials in broker logs with tag hidden You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka K

[jira] [Commented] (KAFKA-5094) Censor SCRAM config change logging

[ https://issues.apache.org/jira/browse/KAFKA-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976518#comment-15976518 ] ASF GitHub Bot commented on KAFKA-5094: --- GitHub user rajinisivaram opened a pull req

[jira] [Updated] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Di Giulio updated KAFKA-5016: -- Attachment: KAFKA_5016.java JUnit test class to reproduce the issue with a 0.10.2.0 brok

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976551#comment-15976551 ] Domenico Di Giulio commented on KAFKA-5016: --- [~vahid] I can reproduce the issue

[GitHub] kafka pull request #2870: MINOR: Fix open file leak in log cleaner integrati...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2870 --- 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-5070) org.apache.kafka.streams.errors.LockException: task [0_18] Failed to lock the state directory: /opt/rocksdb/pulse10/0_18

[ https://issues.apache.org/jira/browse/KAFKA-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976648#comment-15976648 ] Shoyeb Pathan commented on KAFKA-5070: -- [~mjsax] Thanks for reverting back. Can you

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

See Changes: [ismael] MINOR: Fix open file leak in log cleaner integration tests -- [...truncated 716.09 KB...] kafka.api.PlaintextProducerSendTest > testWrongSerializer

[jira] [Commented] (KAFKA-5094) Censor SCRAM config change logging

[ https://issues.apache.org/jira/browse/KAFKA-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976735#comment-15976735 ] Ismael Juma commented on KAFKA-5094: [~jstrom], any chance you could verify the fix in

[jira] [Commented] (KAFKA-5094) Censor SCRAM config change logging

[ https://issues.apache.org/jira/browse/KAFKA-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15976744#comment-15976744 ] Johan Ström commented on KAFKA-5094: [~ijuma] My scala is pretty basic.. But from what

[jira] [Created] (KAFKA-5096) Check Streams user config parameter earlier

Matthias J. Sax created KAFKA-5096: -- Summary: Check Streams user config parameter earlier Key: KAFKA-5096 URL: https://issues.apache.org/jira/browse/KAFKA-5096 Project: Kafka Issue Type: Imp

[jira] [Assigned] (KAFKA-5096) Check Streams user config parameter earlier

[ https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mariam John reassigned KAFKA-5096: -- Assignee: Mariam John > Check Streams user config parameter earlier > -

[jira] [Reopened] (KAFKA-4980) testReprocessingFromScratch unit test failure

[ https://issues.apache.org/jira/browse/KAFKA-4980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-4980: Reopening this, as the fix should get cherry-picked to {{0.10.2}}: https://github.com/apache/ka

[jira] [Updated] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4755: Summary: SimpleBenchmark test fails for streams (was: SimpleBenchmark consume test fails for stream

[jira] [Updated] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4755: Fix Version/s: 0.10.2.1 > SimpleBenchmark test fails for streams > -

[jira] [Created] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

Ismael Juma created KAFKA-5097: -- Summary: KafkaConsumer.poll throws IllegalStateException Key: KAFKA-5097 URL: https://issues.apache.org/jira/browse/KAFKA-5097 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Thanks for the KIP! While I agree, that the current API is not perfect, I am not sure if a builder pattern does make sense here, because it's not too many parameters. IMHO, builder pattern makes sense if there are many optional parameters. For a ProducerRecord, I think there are only 2 optional p

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

Florian, I am just wondering: if we keep .toString(), what should the implementation look like? -Matthias On 4/19/17 2:42 PM, Florian Hussonnois wrote: > Hi Matthias, > > So sorry for the delay in replying to you. For now, I think we can keep > KafkaStreams#toString() as it is. > It's always p

[jira] [Updated] (KAFKA-5092) KIP 141 - ProducerRecordBuilder Interface

[ https://issues.apache.org/jira/browse/KAFKA-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5092: --- Labels: kip (was: ) > KIP 141 - ProducerRecordBuilder Interface > ---

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

Hi there, Can't toString() just stay as is? Thanks Eno > On 20 Apr 2017, at 17:26, Matthias J. Sax wrote: > > Florian, > > I am just wondering: if we keep .toString(), what should the > implementation look like? > > > -Matthias > > On 4/19/17 2:42 PM, Florian Hussonnois wrote: >> Hi Matthi

[jira] [Commented] (KAFKA-5089) JAR mismatch in KafkaConnect leads to NoSuchMethodError in HDP 2.6

[ https://issues.apache.org/jira/browse/KAFKA-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977051#comment-15977051 ] Ewen Cheslack-Postava commented on KAFKA-5089: -- Most of that CLASSPATH looks

[jira] [Updated] (KAFKA-5096) Only log invalid user configs and overwrite with correct one

[ https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5096: --- Summary: Only log invalid user configs and overwrite with correct one (was: Check Streams use

[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&focusedCommentId=15977116#comment-15977116 ] Vahid Hashemian commented on KAFKA-4950: [~dpostoronca] Would you mind sharing a b

[jira] [Commented] (KAFKA-4893) async topic deletion conflicts with max topic length

[ https://issues.apache.org/jira/browse/KAFKA-4893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977130#comment-15977130 ] Vahid Hashemian commented on KAFKA-4893: [~soumabrata] Thanks for checking. The so

Re: [DISCUSS] KIP-138: Change punctuate semantics

Hi Michal, Thanks for the KIP. I'd like to propose a bit more of a radical change to the API. 1. deprecate the punctuate method on Processor 2. create a new Functional Interface just for Punctuation, something like: interface Punctuator { void punctuate(long timestamp) } 3. add a new schedule

[jira] [Updated] (KAFKA-5096) Only log invalid user configs and overwrite with correct one

[ https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5096: --- Description: Streams does not allow to overwrite some config parameters (eg, {{enable.auto.co

[jira] [Comment Edited] (KAFKA-5096) Only log invalid user configs and overwrite with correct one

[ https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977190#comment-15977190 ] Matthias J. Sax edited comment on KAFKA-5096 at 4/20/17 6:18 PM: ---

[jira] [Commented] (KAFKA-5096) Only log invalid user configs and overwrite with correct one

[ https://issues.apache.org/jira/browse/KAFKA-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977190#comment-15977190 ] Matthias J. Sax commented on KAFKA-5096: [~johnma] Thanks for picking up this Jira

[jira] [Commented] (KAFKA-4291) TopicCommand --describe shows topics marked for deletion as under-replicated and unavailable

[ https://issues.apache.org/jira/browse/KAFKA-4291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977214#comment-15977214 ] Vahid Hashemian commented on KAFKA-4291: [~mimaison] I opened [KAFKA-4795|https:/

[jira] [Updated] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5097: --- Priority: Blocker (was: Critical) > KafkaConsumer.poll throws IllegalStateException > ---

Re: [VOTE] 0.10.2.1 RC2

Hey Gwen, Eno Thereska found a blocking issue here: https://issues.apache.org/jira/browse/KAFKA-5097. Sorry to say, but we probably need another RC. -Jason On Wed, Apr 19, 2017 at 8:04 AM, Swen Moczarski wrote: > Hi Gwen, > thanks for the new release candidate. Did a quick test, used the RC2 i

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

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dumitru Postoronca updated KAFKA-4950: -- Description: It looks like the when calling {{PartitionStates.partitionSet()}}, while th

[jira] [Commented] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet

[ https://issues.apache.org/jira/browse/KAFKA-451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977280#comment-15977280 ] Jozef Koval commented on KAFKA-451: --- Hi guys, I would like to work on this issue, but nee

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

[ https://issues.apache.org/jira/browse/KAFKA-4950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dumitru Postoronca updated KAFKA-4950: -- Description: It looks like the when calling {{PartitionStates.partitionSet()}}, while th

[jira] [Commented] (KAFKA-454) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[ https://issues.apache.org/jira/browse/KAFKA-454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977292#comment-15977292 ] Jozef Koval commented on KAFKA-454: --- I think this will not fix as the class is deprecated

[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&focusedCommentId=15977294#comment-15977294 ] Dumitru Postoronca commented on KAFKA-4950: --- [~vahid]: updated description with

[jira] [Commented] (KAFKA-523) OffsetRequest handler does not handle errors

[ https://issues.apache.org/jira/browse/KAFKA-523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977300#comment-15977300 ] Jozef Koval commented on KAFKA-523: --- The specified method does not exist anymore. Does it

[jira] [Commented] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977334#comment-15977334 ] Jozef Koval commented on KAFKA-566: --- Dear [~harsha_ch], [~junrao] and [~nehanarkhede]. Ca

[GitHub] kafka pull request #2866: MINOR: Improvements to PID snapshot management

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2866 --- 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] [Resolved] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet

[ https://issues.apache.org/jira/browse/KAFKA-451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-451. --- Resolution: Not A Problem [~jozi-k], thanks for your interest. As Ismael mentioned, this issue actually has al

[jira] [Commented] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977388#comment-15977388 ] Jozef Koval commented on KAFKA-617: --- Hi [~jkreps], I would like to work on this issue, bu

[jira] [Work started] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5097 started by Eno Thereska. --- > KafkaConsumer.poll throws IllegalStateException > ---

[jira] [Commented] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977395#comment-15977395 ] Jun Rao commented on KAFKA-566: --- [~jozi-k], thanks for your interest. I am not sure if [~srih

[jira] [Commented] (KAFKA-4667) Connect should create internal topics

[ https://issues.apache.org/jira/browse/KAFKA-4667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977460#comment-15977460 ] Gwen Shapira commented on KAFKA-4667: - Also, note that validating configuration of exi

[GitHub] kafka pull request #2769: KAFKA-4937: Batch offset fetches in the Consumer

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2769 --- 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] [Resolved] (KAFKA-4937) Batch resetting offsets in Streams' StoreChangelogReader

[ https://issues.apache.org/jira/browse/KAFKA-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4937. -- Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 2769 [https://gi

[jira] [Commented] (KAFKA-4937) Batch resetting offsets in Streams' StoreChangelogReader

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

[jira] [Resolved] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

[ https://issues.apache.org/jira/browse/KAFKA-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5097. Resolution: Fixed Issue resolved by pull request 2876 [https://github.com/apache/kafka/pull/

[GitHub] kafka pull request #2836: MINOR: improve test stability for Streams broker-c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2836 --- 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] [Comment Edited] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15970549#comment-15970549 ] Joseph Aliase edited comment on KAFKA-5007 at 4/20/17 8:50 PM: -

[jira] [Updated] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Aliase updated KAFKA-5007: - Attachment: jstack-zoo.out jstack-kafka.out lsofkafka.txt

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977499#comment-15977499 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] Thanks a lot for sharing th

[jira] [Comment Edited] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977495#comment-15977495 ] Joseph Aliase edited comment on KAFKA-5007 at 4/20/17 9:01 PM: -

[jira] [Comment Edited] (KAFKA-5007) Kafka Replica Fetcher Thread- Resource Leak

[ https://issues.apache.org/jira/browse/KAFKA-5007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977495#comment-15977495 ] Joseph Aliase edited comment on KAFKA-5007 at 4/20/17 9:01 PM: -

[jira] [Resolved] (KAFKA-5014) SSL Channel not ready but tcp is established and the server is hung will not sending metadata

[ https://issues.apache.org/jira/browse/KAFKA-5014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5014. Resolution: Fixed Issue resolved by pull request 2813 [https://github.com/apache/kafka/pull/

[GitHub] kafka pull request #2813: KAFKA-5014: NetworkClient.leastLoadedNode should c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2813 --- 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-5014) SSL Channel not ready but tcp is established and the server is hung will not sending metadata

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

[GitHub] kafka pull request #2789: MINOR: reduce commit interval and cache size for i...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2789 --- 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-4795) Confusion around topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977538#comment-15977538 ] Edoardo Comar commented on KAFKA-4795: -- [~vahid] I may still see topics ??marked for

[jira] [Comment Edited] (KAFKA-4795) Confusion around topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977538#comment-15977538 ] Edoardo Comar edited comment on KAFKA-4795 at 4/20/17 9:13 PM: -

[jira] [Comment Edited] (KAFKA-4795) Confusion around topic deletion

[ https://issues.apache.org/jira/browse/KAFKA-4795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977538#comment-15977538 ] Edoardo Comar edited comment on KAFKA-4795 at 4/20/17 9:15 PM: -

[DISCUSS] KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster

Hi all, While working on the AdminClient, we determined that we didn't have a way to efficiently list all the topics in the cluster. I wrote up a KIP to add a ListTopicsRequest to make this more efficient in larger clusters with more brokers and topics. Please take a look at the KIP here: https

[jira] [Updated] (KAFKA-5037) Infinite loop if all input topics are unknown at startup

[ https://issues.apache.org/jira/browse/KAFKA-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5037: - Labels: user-experience (was: ) > Infinite loop if all input topics are unknown at startup >

[GitHub] kafka pull request #2834: KAFKA-5047: NullPointerException while using Globa...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2834 --- 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-5047) NullPointerException while using GlobalKTable in KafkaStreams

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

[jira] [Updated] (KAFKA-5047) NullPointerException while using GlobalKTable in KafkaStreams

[ https://issues.apache.org/jira/browse/KAFKA-5047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5047: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

[jira] [Assigned] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3502: Assignee: (was: Guozhang Wang) > Build is killed during kafka streams tests due to `pur

[jira] [Commented] (KAFKA-3502) Build is killed during kafka streams tests due to `pure virtual method called` error

[ https://issues.apache.org/jira/browse/KAFKA-3502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977574#comment-15977574 ] Guozhang Wang commented on KAFKA-3502: -- [~enothereska] could you list the details on

[GitHub] kafka pull request #2856: KAFKA-5073: Kafka Streams stuck rebalancing after ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2856 --- 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-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5006: - Labels: user-experience (was: ) > KeyValueStore.put may throw exception unrelated to the current

[jira] [Updated] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

[ https://issues.apache.org/jira/browse/KAFKA-5073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5073: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

[jira] [Commented] (KAFKA-5073) Kafka Streams stuck rebalancing after exception thrown in rebalance listener

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

[GitHub] kafka pull request #2876: KAFKA-5097: guard against unassigned partitions

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2876 --- 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

[jira] [Commented] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

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

[jira] [Commented] (KAFKA-5006) KeyValueStore.put may throw exception unrelated to the current put attempt

[ https://issues.apache.org/jira/browse/KAFKA-5006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15977593#comment-15977593 ] Guozhang Wang commented on KAFKA-5006: -- [~xvrl] Thanks for reporting the issue. After

[GitHub] kafka pull request #2877: KAFKA-5095: Adjust accepted overhead

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2877 --- 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] [Resolved] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5095. -- Resolution: Fixed Fix Version/s: 0.10.2.1 0.11.0.0 Issue resolved by p

[jira] [Commented] (KAFKA-5095) ThreadCacheTest.cacheOverheadsSmallValues fails intermittently

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

Re: [DISCUSS] KIP-126 - Allow KafkaProducer to batch based on uncompressed size

Thanks for the explanation. I agree that it is not easy to have a well-defined and accurate measurement of the split ratio. On Wed, Apr 19, 2017 at 9:38 AM, Becket Qin wrote: > Thanks for the comment, Dong. I think the batch-split-ratio makes sense but > is kind of redundant to batch-split-rate.

  1   2   >