Re: [DISCUSS] KIP-80: Kafka REST Server

+ 1 to rest client (don't mind if it's the current confluent version or something else) We are a multi language company and the quality of the other clients that are not Java are really hit and miss. A rest endpoint a user could just pump messages into or subscribe to would be amazing. On Sun, Oc

[jira] [Closed] (KAFKA-3776) Unify store and downstream caching in streams

[ https://issues.apache.org/jira/browse/KAFKA-3776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska closed KAFKA-3776. --- > Unify store and downstream caching in streams > - > >

[jira] [Updated] (KAFKA-3779) Add the LRU cache for KTable.to() operator

[ https://issues.apache.org/jira/browse/KAFKA-3779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-3779: Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-3776) > Add the LRU cache f

[jira] [Updated] (KAFKA-4168) More precise accounting of memory usage

[ https://issues.apache.org/jira/browse/KAFKA-4168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska updated KAFKA-4168: Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-3776) > More precise accoun

Re: [DISCUSS] KIP-80: Kafka REST Server

Neha & Jay, We did look at the open source alternatives. Our concern is what's the patch acceptance and adding features/ bug-fixes to the existing project under a Github (although it's licensed under Apache 2.0). It would be great if that project made available under Apache and dri

[jira] [Updated] (KAFKA-4245) BlockingChannel#connect hides all exceptions

[ https://issues.apache.org/jira/browse/KAFKA-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabriel Reid updated KAFKA-4245: Status: Patch Available (was: Open) > BlockingChannel#connect hides all exceptions > --

[jira] [Commented] (KAFKA-4245) BlockingChannel#connect hides all exceptions

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

[GitHub] kafka pull request #1948: KAFKA-4245: Don't swallow IOExceptions

GitHub user gabrielreid opened a pull request: https://github.com/apache/kafka/pull/1948 KAFKA-4245: Don't swallow IOExceptions Remove swallowing of exceptions from BlockingChannel#connect. This commit also slightly reworks the handling of a BlockingChannel in KafkaServe

[jira] [Updated] (KAFKA-4245) BlockingChannel#connect hides all exceptions

[ https://issues.apache.org/jira/browse/KAFKA-4245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabriel Reid updated KAFKA-4245: Affects Version/s: (was: 0.8.1) 0.8.2.0 > BlockingChannel#connect hides a

[jira] [Created] (KAFKA-4245) BlockingChannel#connect hides all exceptions

Gabriel Reid created KAFKA-4245: --- Summary: BlockingChannel#connect hides all exceptions Key: KAFKA-4245 URL: https://issues.apache.org/jira/browse/KAFKA-4245 Project: Kafka Issue Type: Bug

Build failed in Jenkins: kafka-0.10.1-jdk7 #38

See Changes: [wangguoz] KAFKA-4241: StreamsConfig doesn't pass through custom consumer and -- [...truncated 6785 lines...] kafka.common.ConfigTest > testInvalidClientIds PASSED kafka.common.ZkNo

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

See Changes: [wangguoz] KAFKA-4241: StreamsConfig doesn't pass through custom consumer and -- [...truncated 1752 lines...] kafka.api.AuthorizerIntegrationTest > testCreatePermissionNeededToRead