[
https://issues.apache.org/jira/browse/KAFKA-3531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani updated KAFKA-3531:
--
Assignee: Parth Brahmbhatt
> support subnet in ACL tool
> --
[
https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sriharsha Chintalapani reassigned KAFKA-3532:
-
Assignee: Sriharsha Chintalapani
> add principal.builder.class that can e
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233745#comment-15233745
]
James Cheng commented on KAFKA-3042:
I was also connected using zkCli.sh at the same t
[
https://issues.apache.org/jira/browse/KAFKA-3527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233722#comment-15233722
]
Liquan Pei commented on KAFKA-3527:
---
[~jasong35] Do you mind if I take this?
> Consume
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233630#comment-15233630
]
Robert Christ edited comment on KAFKA-3042 at 4/9/16 6:53 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233630#comment-15233630
]
Robert Christ edited comment on KAFKA-3042 at 4/9/16 6:53 PM:
--
Mike,
Not clear what do you mean by "buffering up the contents". Producer itself
already did some buffering and batching when sending to Kafka. Did you
actually "merge" multiple small messages into one large message before
giving it to the producer in the app code? In either case, I am not sure
ho
Sounds good.
On Fri, Apr 8, 2016 at 11:37 AM, Grant Henke wrote:
> Guozhang,
>
> I agree there is a gap. Thats what I was trying to say in the last email.
> But I also, don't see a great/safe way to fix it by changing what topics
> are included in the metadata.
>
> Perhaps instead, I can add a s
+1
On Fri, Apr 8, 2016 at 4:36 PM, Gwen Shapira wrote:
> +1
>
> On Fri, Apr 8, 2016 at 2:41 PM, Grant Henke wrote:
>
> > I would like to re-initiate the voting process for the "KIP-4 Metadata
> > Schema changes". This is not a vote for all of KIP-4, but specifically
> for
> > the metadata chang
[
https://issues.apache.org/jira/browse/KAFKA-3521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-3521:
-
Fix Version/s: (was: 0.10.1.0)
0.10.0.0
> Better handling NPEs in Streams D
GitHub user SinghAsDev opened a pull request:
https://github.com/apache/kafka/pull/1211
MINOR: Update protocol doc link in Introduction.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/SinghAsDev/kafka MinorFixDocLink
Alternativ
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233630#comment-15233630
]
Robert Christ commented on KAFKA-3042:
--
Hi Flavio,
The logs can be found at:
https:
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233564#comment-15233564
]
Flavio Junqueira commented on KAFKA-3042:
-
[~delbaeth] thanks for all the informat
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15232535#comment-15232535
]
Flavio Junqueira edited comment on KAFKA-3042 at 4/9/16 1:09 PM:
---
Guozhang,
In my processor, I'm buffering up contents of the final messages in order to
make them larger. This is to optimize throughput and avoid tiny messages from
being injected downstream. So nothing is being pushed to the producer until my
configured thresholds are met in the buffering me
The flush interval is controlled by offset.flush.interval.ms, which is
the Interval at which to try committing offsets for tasks. You can find the
documentation for this config at
http://docs.confluent.io/2.0.1/connect/userguide.html#configuring-workers
-Liquan
On Fri, Apr 8, 2016 at 8:19 PM, vic
GitHub user stepio opened a pull request:
https://github.com/apache/kafka/pull/1210
MINOR: fix incorrect exception message
While playing with client got the next exception:
```java
java.lang.IllegalArgumentException: Invalid partition given with record: 1
is not in the range
17 matches
Mail list logo
