[jira] [Commented] (KAFKA-5642) Use async ZookeeperClient in Controller

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

[jira] [Created] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory

Alexander Petrovsky created KAFKA-5814: -- Summary: java.lang.OutOfMemoryError: Direct buffer memory Key: KAFKA-5814 URL: https://issues.apache.org/jira/browse/KAFKA-5814 Project: Kafka Is

[jira] [Updated] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory

[ https://issues.apache.org/jira/browse/KAFKA-5814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Petrovsky updated KAFKA-5814: --- Description: Hello! We have in our production - kafka_2.12-0.10.2.1 - # java -versi

[jira] [Commented] (KAFKA-5778) Kafka cluster is not responding when one broker hangs and resulted in too many connections in close_wait in other brokers

[ https://issues.apache.org/jira/browse/KAFKA-5778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148669#comment-16148669 ] Jungbae Jun commented on KAFKA-5778: I had experienced for 3 times in a month, same ve

[jira] [Commented] (KAFKA-5779) Single message may exploit application based on KStream

[ https://issues.apache.org/jira/browse/KAFKA-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148708#comment-16148708 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5779: --- Thanks! > Single m

[jira] [Closed] (KAFKA-5779) Single message may exploit application based on KStream

[ https://issues.apache.org/jira/browse/KAFKA-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-5779. - See Matthias J. Sax comments. > Single message may exploit application based

[jira] [Closed] (KAFKA-5786) Yet another exception is causing that streamming app is zombie

[ https://issues.apache.org/jira/browse/KAFKA-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seweryn Habdank-Wojewodzki closed KAFKA-5786. - See Matthias J. Sax comment. > Yet another exception is causing that streammi

[jira] [Commented] (KAFKA-5786) Yet another exception is causing that streamming app is zombie

[ https://issues.apache.org/jira/browse/KAFKA-5786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148726#comment-16148726 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5786: --- Thanks! I will obse

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148910#comment-16148910 ] Sebastian Bernauer commented on KAFKA-5766: --- Thanks for your reply. What loop a

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16148923#comment-16148923 ] Ismael Juma commented on KAFKA-5766: Can you please try with a newer version? It does

[jira] [Commented] (KAFKA-5650) Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)

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

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149087#comment-16149087 ] Sebastian Bernauer commented on KAFKA-5766: --- Still the same problem Kafka versi

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149090#comment-16149090 ] Ismael Juma commented on KAFKA-5766: cc [~hachikuji] > Very high CPU-load of consumer

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149093#comment-16149093 ] Sebastian Bernauer commented on KAFKA-5766: --- But seems to be fixed in version 2.

[jira] [Comment Edited] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149093#comment-16149093 ] Sebastian Bernauer edited comment on KAFKA-5766 at 8/31/17 2:57 PM:

[jira] [Updated] (KAFKA-4366) KafkaStreams.close() blocks indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Shevchenko updated KAFKA-4366: --- Attachment: threadDump.log Still reproducible in streams 0.11.0.0, see thread dump attached >

[jira] [Comment Edited] (KAFKA-4366) KafkaStreams.close() blocks indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149104#comment-16149104 ] Anna Shevchenko edited comment on KAFKA-4366 at 8/31/17 3:10 PM: ---

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149120#comment-16149120 ] Ismael Juma commented on KAFKA-5766: I don't understand, sorry. You are saying that yo

[jira] [Commented] (KAFKA-2105) NullPointerException in client on MetadataRequest

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

[jira] [Commented] (KAFKA-5379) ProcessorContext.appConfigs() should return parsed/validated values

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

[jira] [Assigned] (KAFKA-2105) NullPointerException in client on MetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-2105: -- Assignee: Manikumar > NullPointerException in client on MetadataRequest > -

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149153#comment-16149153 ] Sebastian Bernauer commented on KAFKA-5766: --- So i've tried the code above with t

[jira] [Resolved] (KAFKA-818) Request failure metrics on the Kafka brokers is not instrumented for all requests

[ https://issues.apache.org/jira/browse/KAFKA-818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-818. - Resolution: Duplicate Similar metrics are proposed in KAFKA-5746. > Request failure metrics on the Kafka b

[jira] [Resolved] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4905. -- Resolution: Not A Problem > StreamPartitionAssignor doesn't respect subscriptions to assign part

[jira] [Commented] (KAFKA-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149176#comment-16149176 ] Guozhang Wang commented on KAFKA-4905: -- We can close it for now. A general issue tho

[jira] [Commented] (KAFKA-5766) Very high CPU-load of consumer when broker is down

[ https://issues.apache.org/jira/browse/KAFKA-5766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149194#comment-16149194 ] Ismael Juma commented on KAFKA-5766: OK, so the newer version of Spring is using a new

[jira] [Resolved] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1447. -- Resolution: Fixed Pl reopen if you think the issue still exists > Controlled shutdown deadlock when t

[jira] [Created] (KAFKA-5815) Add Printed class and KStream#print(Printed)

Damian Guy created KAFKA-5815: - Summary: Add Printed class and KStream#print(Printed) Key: KAFKA-5815 URL: https://issues.apache.org/jira/browse/KAFKA-5815 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

Damian Guy created KAFKA-5816: - Summary: Add Produced class and new to and through overloads to KStream Key: KAFKA-5816 URL: https://issues.apache.org/jira/browse/KAFKA-5816 Project: Kafka Issue

[jira] [Commented] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

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

[jira] [Created] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

Damian Guy created KAFKA-5817: - Summary: Add Serialized class and KStream groupBy and groupByKey overloads Key: KAFKA-5817 URL: https://issues.apache.org/jira/browse/KAFKA-5817 Project: Kafka Is

[jira] [Assigned] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

[ https://issues.apache.org/jira/browse/KAFKA-5817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy reassigned KAFKA-5817: - Assignee: Damian Guy > Add Serialized class and KStream groupBy and groupByKey overloads > --

[jira] [Resolved] (KAFKA-1402) Create unit test helper that stops and starts a cluster

[ https://issues.apache.org/jira/browse/KAFKA-1402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1402. -- Resolution: Fixed We have KafkaServerTestHarness, EmbeddedKafkaCluster, EmbeddedZookeeper helper classe

[jira] [Resolved] (KAFKA-1920) Add a metric to count client side errors in BrokerTopicMetrics

[ https://issues.apache.org/jira/browse/KAFKA-1920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1920. -- Resolution: Duplicate Similar metrics are proposed in KAFKA-5746. > Add a metric to count client side

[jira] [Commented] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

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

[jira] [Resolved] (KAFKA-1138) Remote producer uses the hostname defined in broker

[ https://issues.apache.org/jira/browse/KAFKA-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1138. -- Resolution: Fixed > Remote producer uses the hostname defined in broker > --

[jira] [Resolved] (KAFKA-908) Write duplicate messages during broker failure

[ https://issues.apache.org/jira/browse/KAFKA-908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-908. - Resolution: Fixed Closing inactive issue. Pl reopen if you think the issue still exists > Write duplicate

[jira] [Resolved] (KAFKA-2028) Unable to start the ZK instance after myid file was missing and had to recreate it.

[ https://issues.apache.org/jira/browse/KAFKA-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2028. -- Resolution: Fixed related to config issue. Pl reopen if you think the issue still exists > Unable to

[jira] [Resolved] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior

[ https://issues.apache.org/jira/browse/KAFKA-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2343. -- Resolution: Fixed Javadocs updated in newer versions. > Clarify KafkaConsumer.poll rebalance behavior >

[jira] [Resolved] (KAFKA-2750) Sender.java: handleProduceResponse does not check protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2750. -- Resolution: Fixed This was fixed in KAFKA-4462 /KIP-97 for newer clients > Sender.java: handleProduceRe

[jira] [Resolved] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2842. -- Resolution: Fixed This was fixed in KAFKA-3719 > BrokerEndPoint regex does't support hostname with _ >

[jira] [Resolved] (KAFKA-2897) Class NIOServerCnxn$Factory not found due to mismatch in dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2897. -- Resolution: Won't Fix Closing inactive issue. Pl reopen if you think the issue still exists > Class NIO

[jira] [Resolved] (KAFKA-2986) Consumer group doesn't lend itself well for slow consumers with varying message size

[ https://issues.apache.org/jira/browse/KAFKA-2986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2986. -- Resolution: Fixed Fixed in newer versions. Pl reopen if you think the issue still exists > Consumer g

[jira] [Resolved] (KAFKA-3079) org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error:

[ https://issues.apache.org/jira/browse/KAFKA-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3079. -- Resolution: Cannot Reproduce Mostly related to config error. Pl reopen if you think the issue still exi

[jira] [Resolved] (KAFKA-3647) Unable to set a ssl provider

[ https://issues.apache.org/jira/browse/KAFKA-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3647. -- Resolution: Fixed Closing as per above comments. > Unable to set a ssl provider > -

[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=16149533#comment-16149533 ] Jason Gustafson commented on KAFKA-5016: [~gdstewar] Let me explain the intended b

[jira] [Resolved] (KAFKA-5806) Fix transient unit test failure in trogdor coordinator shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5806. Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 3755 [https://g

[jira] [Commented] (KAFKA-5806) Fix transient unit test failure in trogdor coordinator shutdown

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

[jira] [Commented] (KAFKA-4366) KafkaStreams.close() blocks indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-4366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149596#comment-16149596 ] Matthias J. Sax commented on KAFKA-4366: [~pvg] You should use the newly introduce

[jira] [Created] (KAFKA-5818) Kafka Stream state transitions not correct

Matthias J. Sax created KAFKA-5818: -- Summary: Kafka Stream state transitions not correct Key: KAFKA-5818 URL: https://issues.apache.org/jira/browse/KAFKA-5818 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5818) Kafka Stream state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5818: --- Affects Version/s: 0.11.0.0 > Kafka Stream state transitions not correct > ---

[jira] [Updated] (KAFKA-5818) Kafka Stream state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5818: --- Affects Version/s: (was: 0.11.0.0) 1.0.0 0.11

[jira] [Updated] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5818: --- Summary: KafkaStreams state transitions not correct (was: Kafka Stream state transitions not

[jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct

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

[jira] [Updated] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5818: --- Fix Version/s: 1.0.0 0.11.0.1 > KafkaStreams state transitions not correct

[jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149786#comment-16149786 ] Ted Yu commented on KAFKA-5818: --- Looking at StreamThread, in the call chain run() -> runLoop

[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=16149830#comment-16149830 ] Richard Yu commented on KAFKA-4468: --- [~mjsax] Can you ask Bill to review my updates? Th

[jira] [Comment Edited] (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=16149830#comment-16149830 ] Richard Yu edited comment on KAFKA-4468 at 9/1/17 12:23 AM: [~

[jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149928#comment-16149928 ] Richard Yu commented on KAFKA-4217: --- [~guozhang] The flatTransform method that you menti

[jira] [Comment Edited] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149928#comment-16149928 ] Richard Yu edited comment on KAFKA-4217 at 9/1/17 2:26 AM: --- [~gu

[jira] [Comment Edited] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149928#comment-16149928 ] Richard Yu edited comment on KAFKA-4217 at 9/1/17 2:29 AM: --- [~gu

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149937#comment-16149937 ] Genmao Yu commented on KAFKA-4763: -- {{If a broker starts with some replicas unavailable b

[jira] [Comment Edited] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149937#comment-16149937 ] Genmao Yu edited comment on KAFKA-4763 at 9/1/17 2:34 AM: -- [~lind

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149954#comment-16149954 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] Can you be more specific which part or whic

[jira] [Commented] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149971#comment-16149971 ] Guozhang Wang commented on KAFKA-4217: -- {{valueTransformerSupplier}} will return a {{

[jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149975#comment-16149975 ] Guozhang Wang commented on KAFKA-5818: -- Yes, because state is volatile, we only need

[jira] [Commented] (KAFKA-5818) KafkaStreams state transitions not correct

[ https://issues.apache.org/jira/browse/KAFKA-5818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149980#comment-16149980 ] Ted Yu commented on KAFKA-5818: --- {code} public synchronized boolean isRunningAndNotRebal

[jira] [Resolved] (KAFKA-4188) compilation issues with org.apache.kafka.clients.consumer.internals.Fetcher.java

[ https://issues.apache.org/jira/browse/KAFKA-4188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4188. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > compilation issues with

[jira] [Updated] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate.

[ https://issues.apache.org/jira/browse/KAFKA-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raoufeh Hashemian updated KAFKA-5781: - Attachment: server.log gc0.log controler.log

[jira] [Commented] (KAFKA-5781) Frequent long produce latency periods that result in reduced produce rate.

[ https://issues.apache.org/jira/browse/KAFKA-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150090#comment-16150090 ] Raoufeh Hashemian commented on KAFKA-5781: -- Just attached the log files and a plo

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150112#comment-16150112 ] Genmao Yu commented on KAFKA-4763: -- [~lindong] IMHO, it is OK to re-create the lost repli

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150115#comment-16150115 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] Le's say we have a broker of 2 disks. Each

[jira] [Comment Edited] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150115#comment-16150115 ] Dong Lin edited comment on KAFKA-4763 at 9/1/17 6:40 AM: - [~uncleG

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150130#comment-16150130 ] Genmao Yu commented on KAFKA-4763: -- [~lindong] hmm, make sense. What happens if remaining

[jira] [Comment Edited] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150130#comment-16150130 ] Genmao Yu edited comment on KAFKA-4763 at 9/1/17 6:48 AM: -- [~lind

[jira] [Commented] (KAFKA-4763) Handle disk failure for JBOD (KIP-112)

[ https://issues.apache.org/jira/browse/KAFKA-4763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16150131#comment-16150131 ] Dong Lin commented on KAFKA-4763: - [~uncleGen] The current design don't use remaining disk

[jira] [Resolved] (KAFKA-4411) broker don't have access to kafka zookeeper nodes

[ https://issues.apache.org/jira/browse/KAFKA-4411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4411. -- Resolution: Not A Problem It is necessary to have the same principal name across all brokers for ZK Au