Re: [ANNOUNCE] New committer: Damian Guy

Congrats, Damien! 2017-06-12 8:44 GMT+02:00 Rajini Sivaram : > Congratulations, Damian! > > On Sat, Jun 10, 2017 at 12:15 PM, Mickael Maison > > wrote: > > > Congrats Damian! > > > > On Sat, Jun 10, 2017 at 8:46 AM, Damian Guy > wrote: > > > Thanks everyone. Looking forward to making many more

Test fail reason on doc fix

Hi all, I opened this JIRA with a related PR few days ago : https://github.com/apache/kafka/pull/3269 https://issues.apache.org/jira/browse/KAFKA-5410 It's just a fix on a documentation file but in the PR I see a Test FAILed (JDK 7 and Scala 2.11) with no more information about that. Becaus

[jira] [Commented] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046325#comment-16046325 ] Paolo Patierno commented on KAFKA-5412: --- Sorry [~rhauch], on what version do you mea

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

See -- [...truncated 4.20 MB...] kafka.integration.PrimitiveApiTest > testMultiProduce PASSED kafka.integration.PrimitiveApiTest > testDefaultEncoderProducerAndFetch STARTED kafka.inte

[GitHub] kafka pull request #3301: MINOR: Avoiding attempt to connect to Zookeeper on...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3301 MINOR: Avoiding attempt to connect to Zookeeper on closing consumer for deleting random group.id with the new one With the new consumer the "/consumers" path on Zookeeper isn't filled by consumer

Re: Test fail reason on doc fix

Hi Paolo, Usually you can just follow the links added by asfbot on the PR, but these are currently giving 404 (and not just for your failures, so maybe an ASF infrastructure problem?) Cheers, Tom On 12 June 2017 at 09:20, Paolo Patierno wrote: > Hi all, > > > I opened this JIRA with a related

Re: Test fail reason on doc fix

Hi Tom, this is the problem I noticed for this reason asked here. Btw I don't understand the reason for a failure on a simple doc fix (inside the HTML file) :-) Thanks, Paolo Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows Embedded & IoT Microsoft Azure Adv

Re: Test fail reason on doc fix

Some tests are intermittently failing, it may go away when you retest. You can trigger a retest by putting a comment "Retest this please" on your PR. Hope that helps, Michał On 12/06/17 10:19, Paolo Patierno wrote: Hi Tom, this is the problem I noticed for this reason asked here. Btw I do

[jira] [Assigned] (KAFKA-5418) ZkUtils.getAllPartitions() may fail if a topic is marked for deletion

[ https://issues.apache.org/jira/browse/KAFKA-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-5418: Assignee: Edoardo Comar > ZkUtils.getAllPartitions() may fail if a topic is marked for dele

[jira] [Created] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

Carsten Rietz created KAFKA-5431: Summary: LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException Key: KAFKA-5431 URL: https://issues.apache.org/jira/browse/KAFKA-5431 Project

[GitHub] kafka pull request #3302: KAFKA-5409: Providing a custom client-id to the Co...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3302 KAFKA-5409: Providing a custom client-id to the ConsoleProducer tool You can merge this pull request into a Git repository by running: $ git pull https://github.com/ppatierno/kafka kafka-540

[jira] [Commented] (KAFKA-5409) Providing a custom client-id to the ConsoleProducer tool

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

[jira] [Created] (KAFKA-5432) producer and consumer SocketTimeoutException

Jian Lin created KAFKA-5432: --- Summary: producer and consumer SocketTimeoutException Key: KAFKA-5432 URL: https://issues.apache.org/jira/browse/KAFKA-5432 Project: Kafka Issue Type: Bug C

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5432) producer and consumer SocketTimeoutException

[ https://issues.apache.org/jira/browse/KAFKA-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jian Lin updated KAFKA-5432: Description: Hey all, I met a strange problem, hope someone can help me. The program ran normally for a week

[jira] [Updated] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5431: --- Labels: reliability (was: ) > LogCleaner stopped due to > org.apache.kafka.common.errors.CorruptReco

[jira] [Commented] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046480#comment-16046480 ] Ismael Juma commented on KAFKA-5431: `LogSegment.recover` discards invalid bytes from

[jira] [Commented] (KAFKA-5426) One second delay in kafka-console-producer

[ https://issues.apache.org/jira/browse/KAFKA-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046495#comment-16046495 ] Paolo Patierno commented on KAFKA-5426: --- Hi, the linger.ms parameter is set using th

[jira] [Commented] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams

[ https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046497#comment-16046497 ] Jeyhun Karimov commented on KAFKA-3826: --- [~guozhang] I think KAFKA-4829 also can be

[jira] [Comment Edited] (KAFKA-3826) Sampling on throughput / latency metrics recording in Streams

[ https://issues.apache.org/jira/browse/KAFKA-3826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046497#comment-16046497 ] Jeyhun Karimov edited comment on KAFKA-3826 at 6/12/17 12:32 PM: ---

Re: Test fail reason on doc fix

Thanks Michal ... I have done in this way but now the test which failed is now passed. The other test which was successful is now aborted (https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/5149/). I'll retry with a new "Retest this please" ;) Paolo Patierno Senior Software Engineer (IoT) @

[jira] [Commented] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting

[ https://issues.apache.org/jira/browse/KAFKA-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046534#comment-16046534 ] Bart Vercammen commented on KAFKA-5153: --- [~arpan.khagram0...@gmail.com] Can you conf

[GitHub] kafka pull request #3303: KAFKA-5402: Avoid creating quota related metrics i...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3303 KAFKA-5402: Avoid creating quota related metrics if quotas not enabled You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka

[jira] [Commented] (KAFKA-5402) JmxReporter Fetch metrics for kafka.server should not be created when client quotas are not enabled

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

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046560#comment-16046560 ] Wladimir Schmidt commented on KAFKA-4857: - Will be it addressed in 0.11.0.0 releas

Re: Test fail reason on doc fix

And after two "Retest this please" .. it worked :-) Paolo Patierno Senior Software Engineer (IoT) @ Red Hat Microsoft MVP on Windows Embedded & IoT Microsoft Azure Advisor Twitter : @ppatierno Linkedin : paolopatierno Blog :

[jira] [Created] (KAFKA-5433) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

Rajini Sivaram created KAFKA-5433: - Summary: Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl Key: KAFKA-5433 URL: https://issues.apache.org/jira/browse/KAFKA-5433

[jira] [Commented] (KAFKA-5433) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-5433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046610#comment-16046610 ] Ismael Juma commented on KAFKA-5433: Yes, I saw that error too. :( We need a way to de

[jira] [Resolved] (KAFKA-5405) Request log should log throttle time

[ https://issues.apache.org/jira/browse/KAFKA-5405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5405. Resolution: Fixed Fix Version/s: 0.11.0.0 Merged to trunk and 0.11.0. > Request log should log throt

[jira] [Commented] (KAFKA-5433) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

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

[GitHub] kafka pull request #3304: KAFKA-5433: Close SimpleAclAuthorizer in test to c...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3304 KAFKA-5433: Close SimpleAclAuthorizer in test to close ZK client You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka KAFKA

[GitHub] kafka pull request #3305: MINOR: Specify keyalg RSA for SSL key generation c...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/3305 MINOR: Specify keyalg RSA for SSL key generation commands You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka ssl-doc Alternatively

[jira] [Commented] (KAFKA-5426) One second delay in kafka-console-producer

[ https://issues.apache.org/jira/browse/KAFKA-5426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046638#comment-16046638 ] Francisco commented on KAFKA-5426: -- [~ppatierno] Thank you for your answer!! Then should

[jira] [Commented] (KAFKA-5431) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

[ https://issues.apache.org/jira/browse/KAFKA-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046650#comment-16046650 ] Jun Rao commented on KAFKA-5431: Interesting. First, in general, if there is an IOExceptio

[jira] [Commented] (KAFKA-5412) Using connect-console-sink/source.properties raises an exception related to "file" property not found

[ https://issues.apache.org/jira/browse/KAFKA-5412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046700#comment-16046700 ] Randall Hauch commented on KAFKA-5412: -- [~ppatierno], the committer that reviews and

[jira] [Resolved] (KAFKA-5433) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-5433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5433. --- Resolution: Fixed Fix Version/s: 0.11.1.0 0.11.0.0 Issue resolved by

[GitHub] kafka pull request #3304: KAFKA-5433: Close SimpleAclAuthorizer in test to c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3304 --- 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-5433) Transient test failure: SaslPlainSslEndToEndAuthorizationTest.testNoProduceWithDescribeAcl

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

[jira] [Created] (KAFKA-5434) Console consumer hangs if not existing partition is specified

Paolo Patierno created KAFKA-5434: - Summary: Console consumer hangs if not existing partition is specified Key: KAFKA-5434 URL: https://issues.apache.org/jira/browse/KAFKA-5434 Project: Kafka

[jira] [Created] (KAFKA-5435) Produce state lost if no snapshot retained

Jason Gustafson created KAFKA-5435: -- Summary: Produce state lost if no snapshot retained Key: KAFKA-5435 URL: https://issues.apache.org/jira/browse/KAFKA-5435 Project: Kafka Issue Type: Sub-

[jira] [Commented] (KAFKA-4857) Use AdminClient in Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046763#comment-16046763 ] Guozhang Wang commented on KAFKA-4857: -- I think it will not be included in the 0.11.0

[jira] [Assigned] (KAFKA-5434) Console consumer hangs if not existing partition is specified

[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5434: -- Assignee: Vahid Hashemian > Console consumer hangs if not existing partition is specifi

[jira] [Assigned] (KAFKA-5424) KafkaConsumer.listTopics() throws Exception when unauthorized topics exist in cluster

[ https://issues.apache.org/jira/browse/KAFKA-5424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-5424: - Assignee: Mickael Maison > KafkaConsumer.listTopics() throws Exception when unauthorized

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046796#comment-16046796 ] Matthias J. Sax commented on KAFKA-5245: But {{KStream#groupByKey()}} uses the ser

Re: [DISCUSS] KIP-150 - Kafka-Streams Cogroup

I think we are discussing two separate things here, so it might be worth clarifying: 1) the position of the initializer with respect to the aggregators. If I understand correctly, Guozhang seems to think it is more natural to specify the initializer first, despite it not bearing any relation to th

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Has anyone considered a scheme for sharding topic data across multiple disks? For example, if you sharded topics across 3 disks, and you had 10 disks, you could pick a different set of 3 disks for each topic. If you distribute them randomly then you have 10 choose 3 = 120 different combinations.

Re: 回复：Re： [DISCUSS] KIP-148: Add a connect timeout for client

Just a note: KIP-144 added exponential backoff for broker reconnect attempts, configured via reconnect.backoff.max.ms. cheers, Colin On Sat, Jun 10, 2017, at 08:42, 东方甲乙 wrote: > -- 原始邮件 -- > 发件人: "东方甲乙";<254479...@qq.com>; > 发送时间: 2017年6月4日(星期天) 晚上6:05 > 收件人: "dev

Re: [DISCUSS] KIP-113: Support replicas movement between log directories

Hey Colin, Thanks for the suggestion. We have actually considered this and list this as the first future work in KIP-112 . The two advantages that you mentioned are exactly the motivation for this feature. A

[jira] [Updated] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Ngorok updated KAFKA-5413: --- Attachment: .index.cleaned .log.cleaned

[jira] [Commented] (KAFKA-5145) Remove task close() call from closeNonAssignedSuspendedTasks method

[ https://issues.apache.org/jira/browse/KAFKA-5145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046848#comment-16046848 ] Matthias J. Sax commented on KAFKA-5145: This seems to be a duplicate: https://iss

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046845#comment-16046845 ] Nicholas Ngorok commented on KAFKA-5413: I've uploaded all files pertaining to the

[GitHub] kafka-site pull request #57: New items for the Powered by page

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

[jira] [Commented] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046851#comment-16046851 ] Matthias J. Sax commented on KAFKA-4743: Thanks a lot. Sounds great :) > Add a to

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

See

[GitHub] kafka pull request #3306: KAFKA-5435: Ensure producer snapshot retained afte...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3306 KAFKA-5435: Ensure producer snapshot retained after truncation You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-5435 Alt

[jira] [Commented] (KAFKA-5435) Produce state lost if no snapshot retained

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

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121492476 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046913#comment-16046913 ] Federico Giraud commented on KAFKA-5413: Please let us know if you need any additi

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121496370 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[GitHub] kafka-site pull request #60: Update delivery semantics section for KIP-98

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/60#discussion_r121496464 --- Diff: 0110/design.html --- @@ -261,15 +262,23 @@ It can read the messages, process the messages, and finally save its position. In this

[jira] [Updated] (KAFKA-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

[ https://issues.apache.org/jira/browse/KAFKA-5427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5427: Labels: exactly-once (was: ) > Transactional producer cannot find coordinator when trying to abort

[jira] [Updated] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

[ https://issues.apache.org/jira/browse/KAFKA-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5428: Labels: exactly-once (was: ) > Transactional producer aborts batches incorrectly in abortable error

Re: Changing JIRA notifications to remove Single Email Address (dev@kafka.apache.org)

Thanks for everyone who has spoken out. I have filed https://issues.apache.org/jira/browse/INFRA-14336 to Apache INFRA. Guozhang On Fri, Jun 9, 2017 at 3:07 PM, Matthias J. Sax wrote: > +1 > > On 6/9/17 3:01 PM, Bill Bejeck wrote: > > +1 > > > > Thanks, > > Bill > > > > On Fri, Jun 9, 2017 at

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16046960#comment-16046960 ] Kelvin Rutt commented on KAFKA-5413: I've just had this issue myself. The problem is t

Re: Starting contribution on Apache Kafka project

Hi, any news on this ? I see a lot of activity for the new release so maybe the previous email was lost. :) Thanks ! Paolo From: Paolo Patierno Sent: Wednesday, 7 June, 11:31 Subject: Starting contribution on Apache Kafka project To: dev@kafka.apache.org Hi Kafka devs, I'd like to start con

Re: [ANNOUNCE] New committer: Damian Guy

Congratulations, Damian! On Mon, Jun 12, 2017 at 9:07 AM, Molnár Bálint wrote: > Congrats, Damien! > > 2017-06-12 8:44 GMT+02:00 Rajini Sivaram : > > > Congratulations, Damian! > > > > On Sat, Jun 10, 2017 at 12:15 PM, Mickael Maison < > mickael.mai...@gmail.com > > > > > wrote: > > > > > Congra

[jira] [Updated] (KAFKA-5416) TransactionCoordinator doesn't complete transition to CompleteCommit

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

[GitHub] kafka pull request #3287: KAFKA-5416: Re-prepare transition to CompleteCommi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3287 --- 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-5416) TransactionCoordinator doesn't complete transition to CompleteCommit

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

Re: [ANNOUNCE] New committer: Damian Guy

Congrats! On Mon, Jun 12, 2017 at 12:48 PM, Michael Noll wrote: > Congratulations, Damian! > > On Mon, Jun 12, 2017 at 9:07 AM, Molnár Bálint > wrote: > > > Congrats, Damien! > > > > 2017-06-12 8:44 GMT+02:00 Rajini Sivaram : > > > > > Congratulations, Damian! > > > > > > On Sat, Jun 10, 2017 a

Kafka paper broken link in confluence

On the papers and presentations confluence page [1], the original Kafka paper is now a broken link [2], perhaps because the person who had put it on their site took it down. I saw a few places such as http://notes.stephenholiday.com/Kafka.pdf that ho

[GitHub] kafka pull request #3307: KAFKA-4831: Extract WindowedSerde to public APIs

GitHub user vitaly-pushkar opened a pull request: https://github.com/apache/kafka/pull/3307 KAFKA-4831: Extract WindowedSerde to public APIs Now that we have augmented WindowSerde with non-arg parameters, extract it out as part of the public APIs so that users who want to I/O window

[jira] [Commented] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047003#comment-16047003 ] ASF GitHub Bot commented on KAFKA-4831: --- GitHub user vitaly-pushkar opened a pull re

[jira] [Updated] (KAFKA-4831) Extract WindowedSerde to public APIs

[ https://issues.apache.org/jira/browse/KAFKA-4831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vitaly Pushkar updated KAFKA-4831: -- Reviewer: Guozhang Wang Status: Patch Available (was: In Progress) > Extract WindowedSerd

[jira] [Created] (KAFKA-5436) NullPointerException when loading producer snapshot

Apurva Mehta created KAFKA-5436: --- Summary: NullPointerException when loading producer snapshot Key: KAFKA-5436 URL: https://issues.apache.org/jira/browse/KAFKA-5436 Project: Kafka Issue Type: B

Re: [ANNOUNCE] New committer: Damian Guy

congrats Damian!! Regards, Bharat On Mon, Jun 12, 2017 at 12:52 PM, Konstantine Karantasis < konstant...@confluent.io> wrote: > Congrats! > > On Mon, Jun 12, 2017 at 12:48 PM, Michael Noll > wrote: > > > Congratulations, Damian! > > > > On Mon, Jun 12, 2017 at 9:07 AM, Molnár Bálint > > wrot

[jira] [Commented] (KAFKA-3129) Console producer issue when request-required-acks=0

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047074#comment-16047074 ] Vahid Hashemian commented on KAFKA-3129: [~pmishra01] I tried this on Ubuntu, Wind

[jira] [Created] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

Jason Gustafson created KAFKA-5437: -- Summary: TransactionalMessageCopier should be force killed on test shutdown Key: KAFKA-5437 URL: https://issues.apache.org/jira/browse/KAFKA-5437 Project: Kafka

[GitHub] kafka pull request #3263: KAFKA-5404: Add more AdminClient checks to ClientC...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3263 --- 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-5404) Add more AdminClient checks to ClientCompatibilityTest

[ https://issues.apache.org/jira/browse/KAFKA-5404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5404. Resolution: Fixed Fix Version/s: 0.11.0.0 Issue resolved by pull request 3263 [https://github

[jira] [Commented] (KAFKA-5404) Add more AdminClient checks to ClientCompatibilityTest

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

[jira] [Updated] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

[ https://issues.apache.org/jira/browse/KAFKA-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3123: --- Resolution: Fixed Fix Version/s: (was: 0.11.0.1) 0.11.0.0 Stat

[GitHub] kafka pull request #3296: KAFKA-3123: Follower Broker cannot start if offset...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3296 --- 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-3123) Follower Broker cannot start if offsets are already out of range

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

[jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3978: --- Labels: reliability startup (was: startup) > Cannot truncate to a negative offset (-1) exception at b

[jira] [Assigned] (KAFKA-3123) Follower Broker cannot start if offsets are already out of range

[ https://issues.apache.org/jira/browse/KAFKA-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3123: -- Assignee: Mickael Maison (was: Soumyajit Sahu) > Follower Broker cannot start if offsets are a

[jira] [Updated] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3978: --- Priority: Critical (was: Major) > Cannot truncate to a negative offset (-1) exception at broker start

[jira] [Commented] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047111#comment-16047111 ] Ismael Juma commented on KAFKA-3978: This is the root cause of KAFKA-3123 as well, see

[GitHub] kafka pull request #3305: MINOR: Specify keyalg RSA for SSL key generation c...

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

[GitHub] kafka pull request #3284: MINOR: A few cleanups of usage of Either in TC

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3284 --- 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-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

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

[GitHub] kafka pull request #3297: KAFKA-5427: Transactional producer should allow Fi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3297 --- 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-5427) Transactional producer cannot find coordinator when trying to abort transaction after error

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

[jira] [Updated] (KAFKA-5436) NullPointerException when loading producer snapshot

[ https://issues.apache.org/jira/browse/KAFKA-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5436: Issue Type: Sub-task (was: Bug) Parent: KAFKA-4815 > NullPointerException when loading prod

[GitHub] kafka pull request #3308: KAFKA-5437: Always send a sig_kill when cleaning t...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3308 KAFKA-5437: Always send a sig_kill when cleaning the message copier When the message copier hangs (like when there is a bug in the client), it ignores the sigterm and doesn't shut down. this leaves

[jira] [Commented] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

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

[GitHub] kafka pull request #3308: KAFKA-5437: Always send a sig_kill when cleaning t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3308 --- 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-5437) TransactionalMessageCopier should be force killed on test shutdown

[ https://issues.apache.org/jira/browse/KAFKA-5437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5437. Resolution: Fixed Fix Version/s: (was: 0.11.1.0) 0.11.0.0 Issu

[jira] [Commented] (KAFKA-5437) TransactionalMessageCopier should be force killed on test shutdown

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

  1   2   >