Protocol Documentation WIP

We have gotten a lot of requests for updating the protocol documentation: - KAFKA-3124: Update protocol wiki page to reflect latest request/response formats - KAFKA-2865: Improve Request API Error Code Documentation - KAFKA-3099: Please update A+Guide+To+The+Kafka+Protocol Wiki - KA

[GitHub] kafka pull request: WIP: Protocol Documentation Generation

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/970 WIP: Protocol Documentation Generation Please see the email with the subject "Protocol Documentation WIP" in the Kafka dev mailing list for context on this PR. Do not review this for merge in its

[jira] [Resolved] (KAFKA-2876) Broker allows startup with incompatible listen port/inter-broker protocol settings

[ https://issues.apache.org/jira/browse/KAFKA-2876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-2876. Resolution: Duplicate > Broker allows startup with incompatible listen port/inter-broker protocol >

Build failed in Jenkins: kafka-trunk-jdk7 #1066

See Changes: [wangguoz] KAFKA-2698: Add paused() method to o.a.k.c.c.Consumer -- [...truncated 2418 lines...] kafka.api.PlaintextProducerSendTest > testFlush PASSED kafka.api.PlaintextProducer

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

See Changes: [wangguoz] KAFKA-2698: Add paused() method to o.a.k.c.c.Consumer -- [...truncated 5644 lines...] org.apache.kafka.connect.runtime.WorkerTaskTest > stopBeforeStarting PASSED org.apa

[jira] [Commented] (KAFKA-3257) bootstrap-test-env.sh version check fails when grep has --colour option enabled.

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

[GitHub] kafka pull request: KAFKA-3257: disable bootstrap-test-env.sh --co...

GitHub user zhuchen1018 opened a pull request: https://github.com/apache/kafka/pull/969 KAFKA-3257: disable bootstrap-test-env.sh --colour option @becketqin, when you get a chance, could you take a look at the patch? You can merge this pull request into a Git repository by running:

Build failed in Jenkins: kafka-trunk-jdk7 #1065

See Changes: [wangguoz] MINOR: enhance streams system test -- [...truncated 1479 lines...] kafka.log.LogTest > testReadAtLogGap PASSED kafka.log.LogTest > testTimeBasedLogRoll PASSED kafka.lo

[jira] [Commented] (KAFKA-2698) add paused API

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

[GitHub] kafka pull request: KAFKA-2698: Add paused() method to o.a.k.c.c.C...

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

[jira] [Resolved] (KAFKA-2698) add paused API

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

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

See Changes: [wangguoz] MINOR: enhance streams system test -- [...truncated 5643 lines...] org.apache.kafka.connect.storage.KafkaStatusBackingStoreTest > putConnectorStateShouldOverride PASSED

[jira] [Updated] (KAFKA-2698) add paused API

[ https://issues.apache.org/jira/browse/KAFKA-2698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2698: - Assignee: Jason Gustafson > add paused API > -- > > Key: KAFKA-2698 >

[jira] [Updated] (KAFKA-3280) KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use

[ https://issues.apache.org/jira/browse/KAFKA-3280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Whaling updated KAFKA-3280: --- Flags: Patch > KafkaConsumer Javadoc contains misleading description of heartbeat behavior >

[jira] [Commented] (KAFKA-3280) KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use

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

[GitHub] kafka pull request: KAFKA-3280: KafkaConsumer Javadoc contains mis...

GitHub user rwhaling opened a pull request: https://github.com/apache/kafka/pull/968 KAFKA-3280: KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use This is my original work and I license the work to the project under the project's open sourc

[GitHub] kafka pull request: MINOR: enhance streams system test

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

[jira] [Created] (KAFKA-3280) KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use

Richard Whaling created KAFKA-3280: -- Summary: KafkaConsumer Javadoc contains misleading description of heartbeat behavior and correct use Key: KAFKA-3280 URL: https://issues.apache.org/jira/browse/KAFKA-3280

[jira] [Work started] (KAFKA-3257) bootstrap-test-env.sh version check fails when grep has --colour option enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3257 started by chen zhu. --- > bootstrap-test-env.sh version check fails when grep has --colour option > enabled. > ---

Re: [VOTE] KIP-33 - Add a time based log index to Kafka

Hi Guozhang, I thought about this again and it seems we stilll need the time.index.interval.ms configuration to avoid unnecessary frequent time index insertion. I just updated the wiki to add index.interval.bytes as an additional constraints for time index entry insertion. Another slight change m

Jenkins build is back to normal : kafka-trunk-jdk7 #1064

See

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

See Changes: [wangguoz] MINOR: add retry to state dir locking -- [...truncated 3707 lines...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[1] PASSED kafka.log.BrokerCompressionTe

Re: [VOTE] KIP-33 - Add a time based log index to Kafka

Thanks for the comment Guozhang, I just changed the configuration name to "time.index.interval.ms". It seems the real question here is how big the offset indices will be. Theoretically we can have one time index entry for each message in a log segment. For example, if there is one event per minut

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

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

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163920#comment-15163920 ] Chi Hoang commented on KAFKA-3018: -- I'm going to go ahead and close the PR, and come back

[GitHub] kafka pull request: KAFKA-3018: added topic name validator to Prod...

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

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163893#comment-15163893 ] Jiangjie Qin commented on KAFKA-3018: - I agree that the producer should throw exceptio

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

See Changes: [me] MINOR: add useful debug log messages to KConnect source task execution [junrao] KAFKA-3259 KAFKA-3253; KIP-31/KIP-32 Follow-up -- [...truncated 2953 lines...] kafka.api.SslPro

[jira] [Updated] (KAFKA-3257) bootstrap-test-env.sh version check fails when grep has --colour option enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3257: Assignee: chen zhu > bootstrap-test-env.sh version check fails when grep has --colour option > enabled. > -

Build failed in Jenkins: kafka-trunk-jdk7 #1063

See Changes: [cshapi] MINOR: Add note about which files need to be edited when updating the [me] MINOR: add useful debug log messages to KConnect source task execution [junrao] KAFKA-3259 KAFKA-3253; KIP-31/KIP-32 Follow-up

[GitHub] kafka pull request: MINOR: add retry to state dir locking

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

Re: add karma to jira

Done. Guozhang On Tue, Feb 23, 2016 at 6:00 PM, Christian Posta wrote: > can someone add karma to my username 'ceposta' to be able to assign jira's > to myself? > > thanks! > > -- > *Christian Posta* > twitter: @christianposta > http://www.christianposta.com/blog > http://fabric8.io > -- --

Re: [VOTE] KIP-33 - Add a time based log index to Kafka

Thanks Jiangjie, a few comments on the wiki: 1. Config name "time.index.interval" to "time.index.interval.ms" to be consistent. Also do we need a "time.index.size.max.bytes" as well? 2. Will the memory mapped index file for timestamp have the same default initial / max size (10485760) as the offs

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163731#comment-15163731 ] Grant Henke commented on KAFKA-3018: [~hoangchi], I agree with [~becket_qin] that the

Re: Kafka Version 0.9.0 rebalance question

The new consumers' group metadata is now stored in Kafka instead of zookeeper. The group coordinator will wait for the JoinGroupRequest from all the consumers in the current generation before it moves on to ask group leader assign the partitions. After the consumers passes this barrier, supposedly

Build failed in Jenkins: kafka-trunk-jdk7 #1062

See Changes: [me] KAFKA-3277; Update trunk version to be 0.10.0.0-SNAPSHOT -- [...truncated 2958 lines...] kafka.api.PlaintextConsumerTest > testFetchRecordTooLarge PASSED kafka.api.PlaintextC

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163568#comment-15163568 ] Chi Hoang commented on KAFKA-3018: -- In this case, there are two problems: - the send oper

Re: [VOTE] Make next Kafka release 0.10.0.0 instead of 0.9.1.0

Thanks a lot for help out, Ismael. I was wondering why you changed some of the fix version back to 0.9.1.0 and now I understand. Thanks, Jiangjie (Becket) Qin On Tue, Feb 23, 2016 at 10:37 PM, Ismael Juma wrote: > I also changed the "Fix version" for a number of recent JIRAs from 0.10.0.0 > to

[jira] [Commented] (KAFKA-3259) KIP-31/KIP-32 clean-ups

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

[jira] [Updated] (KAFKA-3253) Skip duplicate message size check if there is no re-compression during log appending.

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

[GitHub] kafka pull request: KAFKA-3259 KAFKA-3253; KIP-31/KIP-32 Follow-up

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

[jira] [Updated] (KAFKA-3259) KIP-31/KIP-32 clean-ups

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

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

See Changes: [me] KAFKA-3277; Update trunk version to be 0.10.0.0-SNAPSHOT [cshapi] MINOR: Add note about which files need to be edited when updating the -- [...truncated 1513 lines...] kafka.a

[GitHub] kafka pull request: Minor: add useful debug log messages to KConne...

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

[jira] [Updated] (KAFKA-3196) KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3196: Status: Patch Available (was: In Progress) > KIP-42 (part 2): add record size and CRC to RecordMeta

[jira] [Updated] (KAFKA-3196) KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-3196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3196: Fix Version/s: 0.10.0.0 > KIP-42 (part 2): add record size and CRC to RecordMetadata and ConsumerRec

[jira] [Updated] (KAFKA-3214) Add consumer system tests for compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3214: Fix Version/s: 0.10.0.0 > Add consumer system tests for compressed topics >

[jira] [Updated] (KAFKA-3214) Add consumer system tests for compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-3214: Status: Patch Available (was: In Progress) > Add consumer system tests for compressed topics >

[jira] [Updated] (KAFKA-3279) SASL implementation checks for unused System property java.security.auth.login.config

[ https://issues.apache.org/jira/browse/KAFKA-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3279: Fix Version/s: 0.10.0.0 > SASL implementation checks for unused System property > java.security.aut

[jira] [Commented] (KAFKA-3018) Kafka producer hangs on producer.close() call if the producer topic contains single quotes in the topic name

[ https://issues.apache.org/jira/browse/KAFKA-3018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163476#comment-15163476 ] Jiangjie Qin commented on KAFKA-3018: - I am not sure if we should let producer to chec

[GitHub] kafka pull request: MINOR: Add note about which files need to be e...

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

[jira] [Commented] (KAFKA-493) High CPU usage on inactive server

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163413#comment-15163413 ] Andrew Olson commented on KAFKA-493: [~cosmin.marginean] You might try upgrading to 0.9

[jira] [Commented] (KAFKA-493) High CPU usage on inactive server

[ https://issues.apache.org/jira/browse/KAFKA-493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15163367#comment-15163367 ] Cosmin Marginean commented on KAFKA-493: Does anyone have any updates on this or wo

[jira] [Reopened] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/KAFKA-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reopened KAFKA-3277: -- > Update trunk version to be 0.10.0.0-SNAPSHOT > ---

[jira] [Resolved] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/KAFKA-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3277. -- Resolution: Fixed > Update trunk version to be 0.10.0.0-SNAPSHOT > -

[jira] [Commented] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

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

[GitHub] kafka pull request: KAFKA-3277; Update trunk version to be 0.10.0....

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

[jira] [Updated] (KAFKA-3277) Update trunk version to be 0.10.0.0-SNAPSHOT

[ https://issues.apache.org/jira/browse/KAFKA-3277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3277: - Resolution: Fixed Fix Version/s: (was: 0.10.1.0) 0.10

[jira] [Updated] (KAFKA-3279) SASL implementation checks for unused System property java.security.auth.login.config

[ https://issues.apache.org/jira/browse/KAFKA-3279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3279: -- Status: Patch Available (was: Open) > SASL implementation checks for unused System property >

[jira] [Commented] (KAFKA-3279) SASL implementation checks for unused System property java.security.auth.login.config

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

[GitHub] kafka pull request: KAFKA-3279: Remove checks for JAAS system prop...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/967 KAFKA-3279: Remove checks for JAAS system property JAAS configuration may be set using other methods and hence the check for System property doesn't always match where the actual configuration

Kafka Version 0.9.0 rebalance question

Hi, after reviewed Kafka 0.9.0 code, I have a rebalance question: coordinator will choose a client as leader to execute assign, after transfer it to coordinator, when assignments are Propagate to each member in consumer group,how can it sure one partition is only owned by a consum

[jira] [Created] (KAFKA-3279) SASL implementation checks for unused System property java.security.auth.login.config

Rajini Sivaram created KAFKA-3279: - Summary: SASL implementation checks for unused System property java.security.auth.login.config Key: KAFKA-3279 URL: https://issues.apache.org/jira/browse/KAFKA-3279

[GitHub] kafka pull request: MINOR: enhance streams system test

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/966 MINOR: enhance streams system test @guozhangwang * add table aggregate to the system test * actually create change log partition replica You can merge this pull request into a Git repo

[jira] [Updated] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

[ https://issues.apache.org/jira/browse/KAFKA-3278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Dearman updated KAFKA-3278: --- Status: Patch Available (was: Open) pull request KAFKA-3278 add thread number to clientId passed into

[jira] [Commented] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

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

[GitHub] kafka pull request: KAFKA-3278 add thread number to clientId passe...

GitHub user tomdearman opened a pull request: https://github.com/apache/kafka/pull/965 KAFKA-3278 add thread number to clientId passed into StreamThread You can merge this pull request into a Git repository by running: $ git pull https://github.com/tomdearman/kafka KAFKA-3278

[GitHub] kafka pull request: Add REST and Connector API to expose connector...

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/964 Add REST and Connector API to expose connector configuration You can merge this pull request into a Git repository by running: $ git pull https://github.com/Ishiihara/kafka expose-connector-c

[jira] [Created] (KAFKA-3278) clientId is not unique in producer/consumer registration leads to mbean warning

Tom Dearman created KAFKA-3278: -- Summary: clientId is not unique in producer/consumer registration leads to mbean warning Key: KAFKA-3278 URL: https://issues.apache.org/jira/browse/KAFKA-3278 Project: Ka

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

See Changes: [me] KAFKA-3093: Add Connect status tracking API -- [...truncated 2962 lines...] kafka.integration.AutoOffsetResetTest > testResetToEarliestWhenOffsetTooLow PASSED kafka.integrati

Build failed in Jenkins: kafka-trunk-jdk7 #1061

See Changes: [me] KAFKA-3093: Add Connect status tracking API -- [...truncated 1480 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdownFile PASSED kafka.