[jira] [Updated] (KAFKA-4307) Inconsistent parameters between console producer and consumer

[ https://issues.apache.org/jira/browse/KAFKA-4307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-4307: - Fix Version/s: 0.11.1.0 > Inconsistent parameters between console producer and consumer >

[jira] [Updated] (KAFKA-5134) Replace zkClient.getChildren method with zkUtils.getChildren

[ https://issues.apache.org/jira/browse/KAFKA-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-5134: - Fix Version/s: 0.11.1.0 > Replace zkClient.getChildren method with zkUtils.getChildren > -

[jira] [Updated] (KAFKA-5127) Replace pattern matching with foreach where the case None is unused

[ https://issues.apache.org/jira/browse/KAFKA-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-5127: - Fix Version/s: 0.11.1.0 > Replace pattern matching with foreach where the case None is unused > -

[jira] [Updated] (KAFKA-5123) Refactor ZkUtils readData* methods

[ https://issues.apache.org/jira/browse/KAFKA-5123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-5123: - Fix Version/s: 0.11.1.0 > Refactor ZkUtils readData* methods > --

[jira] [Updated] (KAFKA-5388) Replace zkClient.subscribe*Changes method with an equivalent zkUtils method

[ https://issues.apache.org/jira/browse/KAFKA-5388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-5388: - Fix Version/s: 0.11.1.0 > Replace zkClient.subscribe*Changes method with an equivalent zkUtils met

[jira] [Commented] (KAFKA-5398) Joins on GlobalKTable don't work properly when combined with Avro and the Confluent Schema Registry

[ https://issues.apache.org/jira/browse/KAFKA-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050225#comment-16050225 ] Benjamin Bargeton commented on KAFKA-5398: -- For sure, but the issue can still hap

[GitHub] kafka pull request #3337: MINOR: Delegated the creation of new Thread to Kaf...

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

[GitHub] kafka pull request #3349: MINOR: Used Kafka native constants in KafkaLog4jAp...

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/3349 MINOR: Used Kafka native constants in KafkaLog4jAppender You can merge this pull request into a Git repository by running: $ git pull https://github.com/Kamal15/kafka log4j2 Alternatively you

[jira] [Comment Edited] (KAFKA-5398) Joins on GlobalKTable don't work properly when combined with Avro and the Confluent Schema Registry

[ https://issues.apache.org/jira/browse/KAFKA-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050225#comment-16050225 ] Benjamin Bargeton edited comment on KAFKA-5398 at 6/15/17 11:39 AM:

[GitHub] kafka pull request #3350: MINOR: Redirected the creation of new Thread to Ka...

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/3350 MINOR: Redirected the creation of new Thread to KafkaThread class. - removed `newThread` & `daemonThread` methods from the Utils. You can merge this pull request into a Git repository by running:

Re: [DISCUSS] KIP-167: Add a restoreAll method to StateRestoreCallback

Thinking about the custom StateRestoreListener approach and having a get method on the interface will really only work for custom state stores. So we'll need to provide another way for users to set behavior with provided state stores. The only option that comes to mind now is also adding a parame

[GitHub] kafka pull request #3351: MINOR: Add --help to DumpLogSegments

GitHub user tombentley opened a pull request: https://github.com/apache/kafka/pull/3351 MINOR: Add --help to DumpLogSegments You can merge this pull request into a Git repository by running: $ git pull https://github.com/tombentley/kafka help Alternatively you can review and

[jira] [Assigned] (KAFKA-4680) min.insync.replicas can be set higher than replication factor

[ https://issues.apache.org/jira/browse/KAFKA-4680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-4680: -- Assignee: Ismael Juma > min.insync.replicas can be set higher than replication factor > ---

[jira] [Updated] (KAFKA-5272) Improve validation for Alter Configs (KIP-133)

[ https://issues.apache.org/jira/browse/KAFKA-5272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5272: --- Summary: Improve validation for Alter Configs (KIP-133) (was: Improve validation for Describe/Alter C

[GitHub] kafka pull request #3352: KAFKA-5454: Add a new Kafka Streams example IoT or...

GitHub user ppatierno opened a pull request: https://github.com/apache/kafka/pull/3352 KAFKA-5454: Add a new Kafka Streams example IoT oriented Added a Kafka Streams example (IoT oriented) using "tumbling" window You can merge this pull request into a Git repository by running:

[jira] [Commented] (KAFKA-5454) Add a new Kafka Streams example IoT oriented

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

[jira] [Created] (KAFKA-5454) Add a new Kafka Streams example IoT oriented

Paolo Patierno created KAFKA-5454: - Summary: Add a new Kafka Streams example IoT oriented Key: KAFKA-5454 URL: https://issues.apache.org/jira/browse/KAFKA-5454 Project: Kafka Issue Type: Impr

[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 ] Paolo Patierno reassigned KAFKA-5434: - Assignee: Paolo Patierno (was: Vahid Hashemian) > Console consumer hangs if not existing

[jira] [Assigned] (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:all-tabpanel ] Paolo Patierno reassigned KAFKA-5409: - Assignee: Paolo Patierno > Providing a custom client-id to the ConsoleProducer tool > ---

[jira] [Assigned] (KAFKA-5410) Fix taskClass() method name in Connector and flush() signature in SinkTask

[ https://issues.apache.org/jira/browse/KAFKA-5410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reassigned KAFKA-5410: - Assignee: Paolo Patierno > Fix taskClass() method name in Connector and flush() signature

[jira] [Assigned] (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:all-tabpanel ] Paolo Patierno reassigned KAFKA-5412: - Assignee: Paolo Patierno > Using connect-console-sink/source.properties raises an excepti

[jira] [Updated] (KAFKA-4879) KafkaConsumer.position may hang forever when deleting a topic

[ https://issues.apache.org/jira/browse/KAFKA-4879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4879: --- Fix Version/s: 0.11.1.0 > KafkaConsumer.position may hang forever when deleting a topic >

[jira] [Updated] (KAFKA-5454) Add a new Kafka Streams example IoT oriented

[ https://issues.apache.org/jira/browse/KAFKA-5454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno updated KAFKA-5454: -- Status: Patch Available (was: Open) > Add a new Kafka Streams example IoT oriented > --

[jira] [Commented] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050793#comment-16050793 ] Steven Schlansker commented on KAFKA-4829: -- This is talking about application log

[jira] [Comment Edited] (KAFKA-4829) Improve logging of StreamTask commits

[ https://issues.apache.org/jira/browse/KAFKA-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050793#comment-16050793 ] Steven Schlansker edited comment on KAFKA-4829 at 6/15/17 5:10 PM: -

[jira] [Commented] (KAFKA-4585) Offset fetch and commit requests use the same permissions

[ https://issues.apache.org/jira/browse/KAFKA-4585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050802#comment-16050802 ] Vahid Hashemian commented on KAFKA-4585: [~ewencp] I'd appreciate your feedback on

[jira] [Updated] (KAFKA-5359) Exceptions from RequestFuture lack parts of the stack trace

[ https://issues.apache.org/jira/browse/KAFKA-5359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-5359: --- Fix Version/s: 0.11.1.0 > Exceptions from RequestFuture lack parts of the stack trace > --

[jira] [Updated] (KAFKA-4416) Add a '--group' option to the console consumer

[ https://issues.apache.org/jira/browse/KAFKA-4416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4416: --- Fix Version/s: 0.11.1.0 > Add a '--group' option to the console consumer > ---

[jira] [Updated] (KAFKA-4333) Report consumer group coordinator id when '--list' option is used

[ https://issues.apache.org/jira/browse/KAFKA-4333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-4333: --- Fix Version/s: 0.11.1.0 > Report consumer group coordinator id when '--list' option is used >

[jira] [Created] (KAFKA-5455) Update java docs for consumer and producer to be up to date for EOS

Apurva Mehta created KAFKA-5455: --- Summary: Update java docs for consumer and producer to be up to date for EOS Key: KAFKA-5455 URL: https://issues.apache.org/jira/browse/KAFKA-5455 Project: Kafka

[jira] [Updated] (KAFKA-5455) Update java docs for consumer and producer to be up to date for EOS

[ https://issues.apache.org/jira/browse/KAFKA-5455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5455: Labels: exactly-once (was: ) > Update java docs for consumer and producer to be up to date for EOS

[jira] [Updated] (KAFKA-5442) Streams producer `client.id` are not unique for EOS

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

[GitHub] kafka pull request #3329: KAFKA-5442: Streams producer client.id are not uni...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3329 --- 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-5442) Streams producer `client.id` are not unique for EOS

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

[jira] [Commented] (KAFKA-5449) Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData

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

[GitHub] kafka pull request #3346: MINOR: Cleanups for TransactionsTest

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

[jira] [Updated] (KAFKA-5417) Clients get inconsistent connection states when SASL/SSL connection is marked CONECTED and DISCONNECTED at the same time

[ https://issues.apache.org/jira/browse/KAFKA-5417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5417: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > Clients get inconsistent connection s

[jira] [Updated] (KAFKA-5032) Think through implications of max.message.size affecting record batches in message format V2

[ https://issues.apache.org/jira/browse/KAFKA-5032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5032: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > Think through implications of max.mes

[jira] [Updated] (KAFKA-5020) Update protocol documentation to mention message format v2

[ https://issues.apache.org/jira/browse/KAFKA-5020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5020: --- Fix Version/s: (was: 0.11.0.0) 0.11.0.1 > Update protocol documentation to ment

[jira] [Assigned] (KAFKA-5449) Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData

[ https://issues.apache.org/jira/browse/KAFKA-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta reassigned KAFKA-5449: --- Assignee: Jason Gustafson (was: Apurva Mehta) > Flaky test TransactionsTest.testReadCommitte

[jira] [Updated] (KAFKA-5449) Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData

[ https://issues.apache.org/jira/browse/KAFKA-5449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apurva Mehta updated KAFKA-5449: Priority: Blocker (was: Major) > Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeU

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16050915#comment-16050915 ] Vahid Hashemian commented on KAFKA-5434: [~ppatierno] I look at this from a differ

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=16050917#comment-16050917 ] Paolo Patierno commented on KAFKA-5434: --- [~vahid] I got your point. Maybe we could h

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

See

[jira] [Resolved] (KAFKA-3056) MirrorMaker with new consumer doesn't handle CommitFailedException

[ https://issues.apache.org/jira/browse/KAFKA-3056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dustin Cote resolved KAFKA-3056. Resolution: Duplicate > MirrorMaker with new consumer doesn't handle CommitFailedException > ---

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

It seems to me that in the most common case the partition isn't going to be magically created and in that case it's more helpful to quit with an error than to sit there waiting for the partition to be created.

[GitHub] kafka pull request #3211: MINOR: make flush no-op as we don't need to call f...

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

[NOTICE] New mailing list for JIRA notifications

Hello All, We have just added a new mailing list in which all JIRA notifications will be sent to. At the same time, will only be notified on "ISSUE {CREATED, RESOLVED, REOPENED}" moving forward. I will update the web docs (https://kafka.apache.org/contact) shortly as well. We hope this will hel

[GitHub] kafka-site pull request #62: MINOR: add jira@kafka mailing list

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka-site/pull/62 MINOR: add jira@kafka mailing list @ijuma please review. We need to wait for merging after the added mailing list appear on http://mail-archives.apache.org/mod_mbox/ You can merge this pull

[GitHub] kafka pull request #3343: MINOR: Add transactionalId in more log lines in th...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3343 --- 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 #3353: KAFKA-5455 - Better Javadocs for the transactional...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3353 KAFKA-5455 - Better Javadocs for the transactional producer You can merge this pull request into a Git repository by running: $ git pull https://github.com/apurvam/kafka KAFKA-5455-proper-jav

Re: [VOTE] KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string

+1 Thanks for the KIP! -Matthias On 6/14/17 6:59 PM, James Chain wrote: > I had start a voting process for KIP-160 > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-160:+Augment+KStream.print()+to+allow+users+pass+in+extra+parameters+in+the+printed+string > signature.asc Descriptio

[jira] [Created] (KAFKA-5456) Producer fails with NPE if record is larger than batch size

Matthias J. Sax created KAFKA-5456: -- Summary: Producer fails with NPE if record is larger than batch size Key: KAFKA-5456 URL: https://issues.apache.org/jira/browse/KAFKA-5456 Project: Kafka

[jira] [Created] (KAFKA-5457) RecordAccumulator.hasRoomfor doesn't take into account the headers while computing available space

Apurva Mehta created KAFKA-5457: --- Summary: RecordAccumulator.hasRoomfor doesn't take into account the headers while computing available space Key: KAFKA-5457 URL: https://issues.apache.org/jira/browse/KAFKA-5457

[GitHub] kafka pull request #3348: KAFKA-5449: Fix race condition on producer dequeui...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3348 --- 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-5449) Flaky test TransactionsTest.testReadCommittedConsumerShouldNotSeeUndecidedData

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

[GitHub] kafka pull request #3354: KAFKA-4829: Improve log4j on Streams thread / task...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3354 KAFKA-4829: Improve log4j on Streams thread / task-level These are the following improvements I made: 1. On stream thread level, INFO will be demonstrating `Completed xx tasks in yy ms

[GitHub] kafka pull request #3355: KAFKA-5457: MemoryRecordsBuilder.hasRoomFor should...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/3355 KAFKA-5457: MemoryRecordsBuilder.hasRoomFor should account for record headers You can merge this pull request into a Git repository by running: $ git pull https://github.com/apurvam/kafka KA

Re: [VOTE] KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string

James, As I commented on the discussion thread, have you considered doing the same for writeAsText as well? Guozhang On Thu, Jun 15, 2017 at 4:33 PM, Matthias J. Sax wrote: > +1 > > Thanks for the KIP! > > > -Matthias > > On 6/14/17 6:59 PM, James Chain wrote: > > I had start a voting process

Re: [VOTE] KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string

+1 On Thu, Jun 15, 2017 at 9:22 PM, Guozhang Wang wrote: > James, > > As I commented on the discussion thread, have you considered doing the same > for writeAsText as well? > > Guozhang > > On Thu, Jun 15, 2017 at 4:33 PM, Matthias J. Sax > wrote: > > > +1 > > > > Thanks for the KIP! > > > > >

Re: [VOTE] KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string

@Guozhang OK, I will add it on writeAsText as well. Should I add writeAsText part in KIP-160 ? James Chien

How should I response mail thread properly?

Hi, Everytime I want to response mail thread like this: origin | ---response | - here I want to [problem] but always got this (ps. I start this mail thread): origin | ---response | here I got [Question] How should I w

[jira] [Created] (KAFKA-5458) SASL handshake fails for METADATA requests

Sagar Lad created KAFKA-5458: Summary: SASL handshake fails for METADATA requests Key: KAFKA-5458 URL: https://issues.apache.org/jira/browse/KAFKA-5458 Project: Kafka Issue Type: Bug Co

[GitHub] kafka pull request #3356: KAFKA-5456: Ensure producer handles old format lar...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3356 KAFKA-5456: Ensure producer handles old format large compressed messages You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA