[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589773#comment-16589773 ] Ayushi commented on KAFKA-5998: --- [~guozhang] Requested files: [^Topology.txt] [^streams.txt

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayushi updated KAFKA-5998: -- Attachment: props.txt streams.txt Topology.txt > /.checkpoint.tmp Not found exc

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayushi updated KAFKA-5998: -- Attachment: properties.txt streamsSnippet.txt topology.txt > /.checkpoint.tmp N

[jira] [Updated] (KAFKA-7330) Kakfa 0.10.2.1 producer close method issue

[ https://issues.apache.org/jira/browse/KAFKA-7330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinay updated KAFKA-7330: - Description: We are creating new producer connections each time but in separate threads(pool of 40 and all threa

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ayushi updated KAFKA-5998: -- Attachment: streamsSnippet.txt topology.txt properties.txt > /.checkpoint.tmp N

[jira] [Resolved] (KAFKA-6314) Add a tool to delete kafka based consumer offsets for a given group

[ https://issues.apache.org/jira/browse/KAFKA-6314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6314. -- Resolution: Duplicate Resolving as duplicate of KAFKA-6275 > Add a tool to delete kafka based consumer

[jira] [Resolved] (KAFKA-1921) Delete offsets for a group with kafka offset storage

[ https://issues.apache.org/jira/browse/KAFKA-1921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1921. -- Resolution: Duplicate Resolving as duplicate of KAFKA-6275 > Delete offsets for a group with kafka off

[jira] [Created] (KAFKA-7330) Kakfa 0.10.2.1 producer close method issue

vinay created KAFKA-7330: Summary: Kakfa 0.10.2.1 producer close method issue Key: KAFKA-7330 URL: https://issues.apache.org/jira/browse/KAFKA-7330 Project: Kafka Issue Type: Bug Components

[jira] [Created] (KAFKA-7329) Continuous warning message of LEADER_NOT_AVAILABLE

Vasudevan Seshadri created KAFKA-7329: - Summary: Continuous warning message of LEADER_NOT_AVAILABLE Key: KAFKA-7329 URL: https://issues.apache.org/jira/browse/KAFKA-7329 Project: Kafka Is

[jira] [Created] (KAFKA-7328) Java version for Kafka

Vasudevan Seshadri created KAFKA-7328: - Summary: Java version for Kafka Key: KAFKA-7328 URL: https://issues.apache.org/jira/browse/KAFKA-7328 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7327) The CPU memory of the kafak master node continues to soar, does not recycle, and finally the service fails?

[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589618#comment-16589618 ] ruiliang commented on KAFKA-7327: - That seems to be the problem. I'll try to upgrade. Tha

[jira] [Updated] (KAFKA-7327) The CPU memory of the kafak master node continues to soar, does not recycle, and finally the service fails?

[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ruiliang updated KAFKA-7327: Summary: The CPU memory of the kafak master node continues to soar, does not recycle, and finally the servi

[jira] [Commented] (KAFKA-7327) kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？

[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589609#comment-16589609 ] Ted Yu commented on KAFKA-7327: --- Have you seen KAFKA-7304 ? BTW my patch over KAFKA-7304 m

[jira] [Commented] (KAFKA-7327) kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？

[ https://issues.apache.org/jira/browse/KAFKA-7327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589606#comment-16589606 ] Ted Yu commented on KAFKA-7327: --- Please use English when reporting bug. How about the follo

[jira] [Created] (KAFKA-7327) kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？

ruiliang created KAFKA-7327: --- Summary: kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？ Key: KAFKA-7327 URL: https://issues.apache.org/jira/browse/KAFKA-7327 Project: Kafka Issue Type: Bug Components: co

[jira] [Commented] (KAFKA-7190) Under low traffic conditions purging repartition topics cause WARN statements about UNKNOWN_PRODUCER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589573#comment-16589573 ] lambdaliu commented on KAFKA-7190: -- Hi [~guozhang] As far as I am concerned , the follow

[jira] [Commented] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

[ https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589533#comment-16589533 ] Dong Lin commented on KAFKA-7128: - [~apovzner] Yes you are right. Previously I stopped at

[jira] [Commented] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

[ https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589473#comment-16589473 ] Anna Povzner commented on KAFKA-7128: - [~lindong] I just saw your comment from Jul 25

[jira] [Updated] (KAFKA-7326) Let KStream.print() to flush on each printed line

[ https://issues.apache.org/jira/browse/KAFKA-7326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7326: --- Affects Version/s: 2.0.0 > Let KStream.print() to flush on each printed line > --

[jira] [Commented] (KAFKA-7326) Let KStream.print() to flush on each printed line

[ https://issues.apache.org/jira/browse/KAFKA-7326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589443#comment-16589443 ] Matthias J. Sax commented on KAFKA-7326: I think we could add a check in `PrintFo

[jira] [Created] (KAFKA-7326) Let KStream.print() to flush on each printed line

Guozhang Wang created KAFKA-7326: Summary: Let KStream.print() to flush on each printed line Key: KAFKA-7326 URL: https://issues.apache.org/jira/browse/KAFKA-7326 Project: Kafka Issue Type: I

[jira] [Commented] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

[ https://issues.apache.org/jira/browse/KAFKA-7157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589428#comment-16589428 ] Ian Axelrod commented on KAFKA-7157: FWIW, I have encountered this as well and it is

[jira] [Commented] (KAFKA-7040) The replica fetcher thread may truncate accepted messages during multiple fast leadership transitions

[ https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589401#comment-16589401 ] Anna Povzner commented on KAFKA-7040: - Hi Lucas, You are right. Looks like this may

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589396#comment-16589396 ] John Wilkinson commented on KAFKA-7314: --- [~omkreddy] As described above, the value

[jira] [Comment Edited] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589389#comment-16589389 ] Joan Goyeau edited comment on KAFKA-7316 at 8/22/18 9:54 PM: -

[jira] [Commented] (KAFKA-7316) Use of filter method in KTable.scala may result in StackOverflowError

[ https://issues.apache.org/jira/browse/KAFKA-7316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589389#comment-16589389 ] Joan Goyeau commented on KAFKA-7316: This [https://github.com/apache/kafka/pull/5539]

[jira] [Updated] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3514: --- Labels: architecture kip (was: architecture) > Stream timestamp computation needs some furth

[jira] [Updated] (KAFKA-3514) Stream timestamp computation needs some further thoughts

[ https://issues.apache.org/jira/browse/KAFKA-3514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3514: --- Description: KIP-353: [https://cwiki.apache.org/confluence/display/KAFKA/KIP-353%3A+Improve+

[jira] [Commented] (KAFKA-5445) Document exceptions thrown by AdminClient methods

[ https://issues.apache.org/jira/browse/KAFKA-5445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589355#comment-16589355 ] ASF GitHub Bot commented on KAFKA-5445: --- adyach opened a new pull request #5558: KA

[jira] [Commented] (KAFKA-6188) Broker fails with FATAL Shutdown - log dirs have failed

[ https://issues.apache.org/jira/browse/KAFKA-6188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589279#comment-16589279 ] Valentina Baljak commented on KAFKA-6188: - Just switched to Kafka 2.0.0. Initial

[jira] [Commented] (KAFKA-7286) Loading offsets and group metadata hangs with large group metadata records

[ https://issues.apache.org/jira/browse/KAFKA-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589263#comment-16589263 ] Flavien Raynaud commented on KAFKA-7286: Any chance anyone could have a look at i

[jira] [Commented] (KAFKA-7128) Lagging high watermark can lead to committed data loss after ISR expansion

[ https://issues.apache.org/jira/browse/KAFKA-7128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589253#comment-16589253 ] ASF GitHub Bot commented on KAFKA-7128: --- apovzner opened a new pull request #5557:

[jira] [Commented] (KAFKA-7305) Offsets should not expire at the record-entry level

[ https://issues.apache.org/jira/browse/KAFKA-7305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589251#comment-16589251 ] Manikumar commented on KAFKA-7305: -- You can take a look at recent change related to Off

[jira] [Commented] (KAFKA-7196) Remove heartbeat delayed operation for those removed consumers at the end of each rebalance

[ https://issues.apache.org/jira/browse/KAFKA-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589247#comment-16589247 ] ASF GitHub Bot commented on KAFKA-7196: --- Lincong opened a new pull request #5556: K

[jira] [Commented] (KAFKA-7306) Ability for producer to push to topic on remote server via ELB name

[ https://issues.apache.org/jira/browse/KAFKA-7306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589240#comment-16589240 ] Manikumar commented on KAFKA-7306: -- check this: https://stackoverflow.com/questions/386

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

[ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589238#comment-16589238 ] Manikumar commented on KAFKA-7314: -- looks like both consumer/producer properties are poi

[jira] [Commented] (KAFKA-7322) race between compaction thread and retention thread when changing topic cleanup policy

[ https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589213#comment-16589213 ] Dhruvil Shah commented on KAFKA-7322: - I think that makes sense, thanks for the confi

[jira] [Commented] (KAFKA-7322) race between compaction thread and retention thread when changing topic cleanup policy

[ https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589199#comment-16589199 ] xiongqi wu commented on KAFKA-7322: --- [~dhruvilshah]  I believe this race condition is d

[jira] [Updated] (KAFKA-7325) Support dynamic gap session window

[ https://issues.apache.org/jira/browse/KAFKA-7325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7325: --- Issue Type: New Feature (was: Improvement) > Support dynamic gap session window > --

[jira] [Commented] (KAFKA-7244) Add note about memory map kernel limits to documentation

[ https://issues.apache.org/jira/browse/KAFKA-7244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589156#comment-16589156 ] Manikumar commented on KAFKA-7244: -- latest docs updated via KAFKA-6343/https://github.co

[jira] [Created] (KAFKA-7325) Support dynamic gap session window

Lei Chen created KAFKA-7325: --- Summary: Support dynamic gap session window Key: KAFKA-7325 URL: https://issues.apache.org/jira/browse/KAFKA-7325 Project: Kafka Issue Type: Improvement Comp

[jira] [Resolved] (KAFKA-6343) OOM as the result of creation of 5k topics

[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-6343. Resolution: Fixed Assignee: Alex Dunayevsky Fix Version/s: 2.1.0 Merged the PR to trunk. >

[jira] [Commented] (KAFKA-6343) OOM as the result of creation of 5k topics

[ https://issues.apache.org/jira/browse/KAFKA-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589131#comment-16589131 ] ASF GitHub Bot commented on KAFKA-6343: --- junrao closed pull request #4358: KAFKA-63

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589111#comment-16589111 ] Guozhang Wang commented on KAFKA-5998: -- And also: is this exception being thrown rig

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589110#comment-16589110 ] Guozhang Wang commented on KAFKA-5998: -- [~ayushi0430] Thanks for reporting on 2.0.0,

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588621#comment-16588621 ] Gunnar Morling commented on KAFKA-3821: --- Hey [~rhauch], [~ewencp] et al., trying to

[jira] [Commented] (KAFKA-3821) Allow Kafka Connect source tasks to produce offset without writing to topics

[ https://issues.apache.org/jira/browse/KAFKA-3821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588619#comment-16588619 ] ASF GitHub Bot commented on KAFKA-3821: --- gunnarmorling opened a new pull request #5

[jira] [Resolved] (KAFKA-7279) partitionsFor implicitly creates topic for the existent topic

[ https://issues.apache.org/jira/browse/KAFKA-7279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7279. -- Resolution: Duplicate Resolving as duplicate of KAFKA-7320/KIP-361 > partitionsFor implicitly creates

[jira] [Commented] (KAFKA-7165) Error while creating ephemeral at /brokers/ids/BROKER_ID

[ https://issues.apache.org/jira/browse/KAFKA-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588600#comment-16588600 ] Manikumar commented on KAFKA-7165: -- [~pachilo] Please send a mail to dev mailing list fo

[jira] [Commented] (KAFKA-6582) Partitions get underreplicated, with a single ISR, and doesn't recover. Other brokers do not take over and we need to manually restart the broker.

[ https://issues.apache.org/jira/browse/KAFKA-6582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588577#comment-16588577 ] Mahdi Yusuf commented on KAFKA-6582: [~chetan027] what ended up resolving the issues

[jira] [Comment Edited] (KAFKA-6985) Error connection between cluster node

[ https://issues.apache.org/jira/browse/KAFKA-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588538#comment-16588538 ] Frank Wang edited comment on KAFKA-6985 at 8/22/18 8:24 AM: [

[jira] [Commented] (KAFKA-7324) NPE due to lack of SASLExtensions in SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-7324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588541#comment-16588541 ] Stanislav Kozlovski commented on KAFKA-7324: Hi Ron, I've updated the issue t

[jira] [Updated] (KAFKA-7324) NPE due to lack of SASLExtensions in SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-7324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7324: --- Fix Version/s: (was: 2.0.1) 2.1.0 > NPE due to lack of SASLExt

[jira] [Commented] (KAFKA-6985) Error connection between cluster node

[ https://issues.apache.org/jira/browse/KAFKA-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588538#comment-16588538 ] Frank Wang commented on KAFKA-6985: --- [2018-08-22 07:27:13,394] WARN [ReplicaFetcher rep

[jira] [Commented] (KAFKA-7290) Kafka Streams application fails to rebalance and is stuck in "Updated cluster metadata version"

[ https://issues.apache.org/jira/browse/KAFKA-7290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588537#comment-16588537 ] Tim Van Laer commented on KAFKA-7290: - Hi [~guozhang] and [~vvcephei],  Thanks for y

[jira] [Updated] (KAFKA-7324) NPE due to lack of SASLExtensions in SASL/OAUTHBEARER

[ https://issues.apache.org/jira/browse/KAFKA-7324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-7324: --- Affects Version/s: (was: 2.0.1) 2.1.0 > NPE due to lack of

[jira] [Commented] (KAFKA-6985) Error connection between cluster node

[ https://issues.apache.org/jira/browse/KAFKA-6985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588534#comment-16588534 ] Frank Wang commented on KAFKA-6985: --- Anybody could give updates? Met the same issue. >