[GitHub] kafka pull request #2703: KAFKA-4772: Use peek to implement print

2017-03-18 Thread backender
GitHub user backender opened a pull request: https://github.com/apache/kafka/pull/2703 KAFKA-4772: Use peek to implement print **Tackles [KAFKA-4772](https://issues.apache.org/jira/browse/KAFKA-4772) and was previously discussed in https://github.com/apache/kafka/pull/2669**

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

2017-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931227#comment-15931227 ] ASF GitHub Bot commented on KAFKA-4772: --- GitHub user backender opened a pull request

[jira] [Commented] (KAFKA-4772) Exploit #peek to implement #print() and other methods

2017-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931229#comment-15931229 ] ASF GitHub Bot commented on KAFKA-4772: --- GitHub user backender opened a pull request

[GitHub] kafka pull request #2704: KAFKA-4772: [WIP] Use KStreamPeek to replace KeyVa...

2017-03-18 Thread backender
GitHub user backender opened a pull request: https://github.com/apache/kafka/pull/2704 KAFKA-4772: [WIP] Use KStreamPeek to replace KeyValuePrinter **Alternative to: https://github.com/apache/kafka/pull/2703 and serves as a reference for discussion.** Tackles [KAFKA-4772](https:

Re: [DISCUSS] KIP-132: Augment KStream.print to allow extra parameters in the printed string

2017-03-18 Thread Marc Juchli
Thanks! I wanted to PING this thread. Not sure what the next steps of the KIP process are? Kind regards, Marc On Wed, Mar 15, 2017 at 9:13 PM Matthias J. Sax wrote: > Thanks for updating the KIP. > > It's in very good shape IMHO and I support this idea! > > > > -Matthias > > > On 3/15/17 3:05

[jira] [Assigned] (KAFKA-4917) Our built-in file connector can't work with our built-in SMT

2017-03-18 Thread Manasvi Gupta (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manasvi Gupta reassigned KAFKA-4917: Assignee: Manasvi Gupta > Our built-in file connector can't work with our built-in SMT > --

[jira] [Assigned] (KAFKA-4912) Add check for topic name length

2017-03-18 Thread Sharad (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sharad reassigned KAFKA-4912: - Assignee: Sharad > Add check for topic name length > --- > >

[GitHub] kafka pull request #2705: KAFKA-4907: message.timestamp.difference.max.ms sh...

2017-03-18 Thread becketqin
GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/2705 KAFKA-4907: message.timestamp.difference.max.ms should not be applied to log compacted topic if user did not set the property. You can merge this pull request into a Git repository by running:

[jira] [Commented] (KAFKA-4907) compacted topic shouldn't reject messages with old timestamp

2017-03-18 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-4907?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15931590#comment-15931590 ] ASF GitHub Bot commented on KAFKA-4907: --- GitHub user becketqin opened a pull request

[jira] [Created] (KAFKA-4918) Continuous fetch requests for offset storage topic in kafka connect

2017-03-18 Thread Liju (JIRA)
Liju created KAFKA-4918: --- Summary: Continuous fetch requests for offset storage topic in kafka connect Key: KAFKA-4918 URL: https://issues.apache.org/jira/browse/KAFKA-4918 Project: Kafka Issue Type: