Re: [DISCUSSION] KIP-422: Add support for user/client configuration in the Kafka Admin Client

2019-03-13 Thread Jun Rao
Hi, Yaodong, Thanks for the updated KIP. A few more comments below. 11. For quotas, in addition to user and client, we need to be able to set a quota for combination. Would that be a new resource type? How would the name look like for this resource? 12. Similarly, to support customizable quota

[jira] [Resolved] (KAFKA-8101) Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8101. Resolution: Not A Bug There is a known issue with KGroupedStream#count in the Scala API where

Re: [VOTE] KIP-415: Incremental Cooperative Rebalancing in Kafka Connect

2019-03-13 Thread Randall Hauch
Excellent work, Konstantine! +1 (binding) On Mon, Mar 11, 2019 at 8:05 PM Konstantine Karantasis < konstant...@confluent.io> wrote: > Thanks Jason! > That makes perfect sense. The change is reflected in the KIP now. > "compatible" will be the default mode for "connect.protocol" > > Cheers, >

[jira] [Created] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

2019-03-13 Thread Gregory Koshelev (JIRA)
Gregory Koshelev created KAFKA-8104: --- Summary: Consumer cannot rejoin to the group after rebalancing Key: KAFKA-8104 URL: https://issues.apache.org/jira/browse/KAFKA-8104 Project: Kafka

Re: Fluent Kafka Streams Test + Schema Registry Mock

2019-03-13 Thread Matthias J. Sax
> At the mean time, some of the syntax sugars >> may be a good learning lessons for AK streams test-utils to improve further >> indeed. I agree with this. In retrospective, the current API has some issues because it can lead to ambiguity. For example `ConsumerRecordFactory#create(K key, V

[jira] [Created] (KAFKA-8103) Kafka SIGSEGV on kafka-network-thread

2019-03-13 Thread Sean Humbarger (JIRA)
Sean Humbarger created KAFKA-8103: - Summary: Kafka SIGSEGV on kafka-network-thread Key: KAFKA-8103 URL: https://issues.apache.org/jira/browse/KAFKA-8103 Project: Kafka Issue Type: Bug

Re: ​Inconsistent state in Account Debit - Credit Application Using Kafka Transaction

2019-03-13 Thread Matthias J. Sax
That is not possible. On read, it's not even known which records belong to the same "write transaction". Note, that this is how transactions work in general: assume you have a database and a transactions updates two rows. After the transaction commits, you can read those updates, but you don't

​Inconsistent state in Account Debit - Credit Application Using Kafka Transaction

2019-03-13 Thread Ankur Saxena
Hi , Please address my issue Account A sends 500 bucks to Account B , We are using a topic Account having multiple partitions to record these events Producer -> Transaction starts Account A BalanceA - 500 to topic Account , partition p0 Account B BalanceB + 500 to topic Account , partition p1

[jira] [Created] (KAFKA-8102) Trogdor - Add Produce workload transaction generator by interval

2019-03-13 Thread Stanislav Kozlovski (JIRA)
Stanislav Kozlovski created KAFKA-8102: -- Summary: Trogdor - Add Produce workload transaction generator by interval Key: KAFKA-8102 URL: https://issues.apache.org/jira/browse/KAFKA-8102 Project:

[jira] [Created] (KAFKA-8101) Optimization Has Different Processor Node Count on Scala API

2019-03-13 Thread Bill Bejeck (JIRA)
Bill Bejeck created KAFKA-8101: -- Summary: Optimization Has Different Processor Node Count on Scala API Key: KAFKA-8101 URL: https://issues.apache.org/jira/browse/KAFKA-8101 Project: Kafka

[jira] [Created] (KAFKA-8100) If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log

2019-03-13 Thread Shengnan YU (JIRA)
Shengnan YU created KAFKA-8100: -- Summary: If delete expired topic, kafka consumer will keep flushing unknown_topic warning in log Key: KAFKA-8100 URL: https://issues.apache.org/jira/browse/KAFKA-8100