[jira] [Resolved] (KAFKA-5084) Allow Kafka connect source tasks to commit offsets without messages being sent

[ https://issues.apache.org/jira/browse/KAFKA-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Riccomini resolved KAFKA-5084. Resolution: Duplicate > Allow Kafka connect source tasks to commit offsets without messa

[jira] [Commented] (KAFKA-5084) Allow Kafka connect source tasks to commit offsets without messages being sent

[ https://issues.apache.org/jira/browse/KAFKA-5084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15973509#comment-15973509 ] Chris Riccomini commented on KAFKA-5084: [~rhauch], hah, this does indeed

[jira] [Created] (KAFKA-5084) Allow Kafka connect source tasks to commit offsets without messages being sent

Chris Riccomini created KAFKA-5084: -- Summary: Allow Kafka connect source tasks to commit offsets without messages being sent Key: KAFKA-5084 URL: https://issues.apache.org/jira/browse/KAFKA-5084

[jira] [Commented] (KAFKA-2376) Add Copycat metrics

[ https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15851926#comment-15851926 ] Chris Riccomini commented on KAFKA-2376: One thing we'd like to see he

[jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15657561#comment-15657561 ] Chris Riccomini commented on KAFKA-4107: Agreed. We've had this need as

[jira] [Commented] (KAFKA-4171) Kafka-connect prints outs keystone and truststore password in log2

[ https://issues.apache.org/jira/browse/KAFKA-4171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15491164#comment-15491164 ] Chris Riccomini commented on KAFKA-4171: Wondering if KC is just put

[jira] [Commented] (KAFKA-2020) I expect ReplicaNotAvailableException to have proper Javadocs

[ https://issues.apache.org/jira/browse/KAFKA-2020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14360624#comment-14360624 ] Chris Riccomini commented on KAFKA-2020: Also related, we'

[jira] [Created] (KAFKA-2020) I expect ReplicaNotAvailableException to have proper Javadocs

Chris Riccomini created KAFKA-2020: -- Summary: I expect ReplicaNotAvailableException to have proper Javadocs Key: KAFKA-2020 URL: https://issues.apache.org/jira/browse/KAFKA-2020 Project: Kafka

[jira] [Commented] (KAFKA-1886) SimpleConsumer swallowing ClosedByInterruptException

[ https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14286326#comment-14286326 ] Chris Riccomini commented on KAFKA-1886: IMO, the SimpleConsumer should at l

[jira] [Commented] (KAFKA-1863) Exception categories / hierarchy in clients

[ https://issues.apache.org/jira/browse/KAFKA-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14278113#comment-14278113 ] Chris Riccomini commented on KAFKA-1863: [~jkreps], so it sounds like we can

[jira] [Commented] (KAFKA-1863) Exception categories / hierarchy in clients

[ https://issues.apache.org/jira/browse/KAFKA-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14278107#comment-14278107 ] Chris Riccomini commented on KAFKA-1863: bq. It might be nice to add a f

[jira] [Comment Edited] (KAFKA-1863) Exception categories / hierarchy in clients

[ https://issues.apache.org/jira/browse/KAFKA-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14277973#comment-14277973 ] Chris Riccomini edited comment on KAFKA-1863 at 1/15/15 12:3

[jira] [Comment Edited] (KAFKA-1863) Exception categories / hierarchy in clients

[ https://issues.apache.org/jira/browse/KAFKA-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14277973#comment-14277973 ] Chris Riccomini edited comment on KAFKA-1863 at 1/15/15 12:3

[jira] [Comment Edited] (KAFKA-1863) Exception categories / hierarchy in clients

[ https://issues.apache.org/jira/browse/KAFKA-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14277973#comment-14277973 ] Chris Riccomini edited comment on KAFKA-1863 at 1/15/15 12:3

[jira] [Commented] (KAFKA-1863) Exception categories / hierarchy in clients

[ https://issues.apache.org/jira/browse/KAFKA-1863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14277973#comment-14277973 ] Chris Riccomini commented on KAFKA-1863: Here's how Samza's Kafka

[jira] [Commented] (KAFKA-1755) Log cleaner thread should not exit on errors

[ https://issues.apache.org/jira/browse/KAFKA-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14198578#comment-14198578 ] Chris Riccomini commented on KAFKA-1755: It might also be desirable to allow

[jira] [Commented] (KAFKA-1639) Support control messages in Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137751#comment-14137751 ] Chris Riccomini commented on KAFKA-1639: One point of discussion is whether

[jira] [Created] (KAFKA-1639) Support control messages in Kafka

Chris Riccomini created KAFKA-1639: -- Summary: Support control messages in Kafka Key: KAFKA-1639 URL: https://issues.apache.org/jira/browse/KAFKA-1639 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-560) Garbage Collect obsolete topics

[ https://issues.apache.org/jira/browse/KAFKA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14128771#comment-14128771 ] Chris Riccomini commented on KAFKA-560: --- bq. It would be good to have a tool

Re: New Consumer API discussion

4 10:19 AM, "Chris Riccomini" wrote: >Hey Guys, > >Sorry for the late follow up. Here are my questions/thoughts on the API: > >1. Why is the config String->Object instead of String->String? > >2. Are these Java docs correct? > > KafkaConsumer(java.util.Map

Re: New Consumer API discussion

Hey Guys, Sorry for the late follow up. Here are my questions/thoughts on the API: 1. Why is the config String->Object instead of String->String? 2. Are these Java docs correct? KafkaConsumer(java.util.Map configs) A consumer is instantiated by providing a set of key-value pairs as configur

[jira] [Commented] (KAFKA-1171) Gradle build for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13844808#comment-13844808 ] Chris Riccomini commented on KAFKA-1171: That sounds a lot like a ver

[jira] [Commented] (KAFKA-1171) Gradle build for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13844780#comment-13844780 ] Chris Riccomini commented on KAFKA-1171: For the record, a good set of exam

[jira] [Commented] (KAFKA-1171) Gradle build for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-1171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13844763#comment-13844763 ] Chris Riccomini commented on KAFKA-1171: For cross-building Scala versions,

[jira] [Commented] (KAFKA-1016) Broker should limit purgatory size

[ https://issues.apache.org/jira/browse/KAFKA-1016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13755167#comment-13755167 ] Chris Riccomini commented on KAFKA-1016: Another interesting behavior seen

[jira] [Commented] (KAFKA-1012) Implement an Offset Manager and hook offset requests to it

[ https://issues.apache.org/jira/browse/KAFKA-1012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13750351#comment-13750351 ] Chris Riccomini commented on KAFKA-1012: Also, what's the gu

[jira] [Commented] (KAFKA-1012) Implement an Offset Manager and hook offset requests to it

[ https://issues.apache.org/jira/browse/KAFKA-1012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13750345#comment-13750345 ] Chris Riccomini commented on KAFKA-1012: >From wiki: "It will likely

[jira] [Commented] (KAFKA-1012) Implement an Offset Manager and hook offset requests to it

[ https://issues.apache.org/jira/browse/KAFKA-1012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13750328#comment-13750328 ] Chris Riccomini commented on KAFKA-1012: Regarding transactionality, as descr

[jira] [Created] (KAFKA-1016) Broker should limit purgatory size

Chris Riccomini created KAFKA-1016: -- Summary: Broker should limit purgatory size Key: KAFKA-1016 URL: https://issues.apache.org/jira/browse/KAFKA-1016 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-982) Logo for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13721217#comment-13721217 ] Chris Riccomini commented on KAFKA-982: --- +1 298, then > L

[jira] [Commented] (KAFKA-982) Logo for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13716567#comment-13716567 ] Chris Riccomini commented on KAFKA-982: --- +1 301 > Logo fo

[jira] [Commented] (KAFKA-925) Add optional partition key override in producer

[ https://issues.apache.org/jira/browse/KAFKA-925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13711676#comment-13711676 ] Chris Riccomini commented on KAFKA-925: --- Hey Jay, Seems pretty reasonable to me

[jira] [Commented] (KAFKA-974) can't use public release maven repo because of failure of downloaded dependency

[ https://issues.apache.org/jira/browse/KAFKA-974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13708819#comment-13708819 ] Chris Riccomini commented on KAFKA-974: --- Hey Joe, This looks really good. Per

[jira] [Created] (KAFKA-725) Broker Exception: Attempt to read with a maximum offset less than start offset

Chris Riccomini created KAFKA-725: - Summary: Broker Exception: Attempt to read with a maximum offset less than start offset Key: KAFKA-725 URL: https://issues.apache.org/jira/browse/KAFKA-725 Project

[jira] [Commented] (KAFKA-715) NumberFormatException in PartitionStateInfo

[ https://issues.apache.org/jira/browse/KAFKA-715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13559021#comment-13559021 ] Chris Riccomini commented on KAFKA-715: --- Indeed, it

[jira] [Created] (KAFKA-715) NumberFormatException in PartitionStateInfo

Chris Riccomini created KAFKA-715: - Summary: NumberFormatException in PartitionStateInfo Key: KAFKA-715 URL: https://issues.apache.org/jira/browse/KAFKA-715 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-709) Default queue.enqueue.timeout.ms to -1

Chris Riccomini created KAFKA-709: - Summary: Default queue.enqueue.timeout.ms to -1 Key: KAFKA-709 URL: https://issues.apache.org/jira/browse/KAFKA-709 Project: Kafka Issue Type: Bug

Re: About kafka 0.8 producer zookeeper-based load balancing on per-request basis

Hey Guys, Correct me if I'm wrong, but I believe in 0.8, the producer uses a metadata request to get topic/partition mappings from the broker. The broker then interacts with ZK (rather than having the producer do it using zk.connect). In the event that the master for a topic/partition fails, a ne