[jira] [Created] (KAFKA-7742) DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API.

2018-12-16 Thread Satish Duggana (JIRA)
Satish Duggana created KAFKA-7742: - Summary: DelegationTokenCache#hmacIdCache entry is not cleared when a token is removed using removeToken(String tokenId) API. Key: KAFKA-7742 URL:

Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements

2018-12-16 Thread Guozhang Wang
Matthias / Paul, The concern I had about introducing `StoreBuilderSupplier` is simply because it is another XXSupplier to the public API, so I'd like to ask if we really have to add it :) The difference between encapsulating the store name and encapsulating the full state store builder is that,

KIP-406: GlobalStreamThread should honor custom reset policy

2018-12-16 Thread Richard Yu
Hi everybody, There is a new KIP regarding the resilience of GlobalStreamThread which could be seen below: https://cwiki.apache.org/confluence/display/KAFKA/KIP-406%3A+GlobalStreamThread+should+honor+custom+reset+policy We are considering the new addition of some new reset policy. It would be

Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements

2018-12-16 Thread Paul Whalen
Thanks for the great thoughts Matthias and Guozhang! If I'm not mistaken, Guozhang's suggestion is what my second alternative on the KIP is ("Have the added method on the Supplier interfaces only return store names, not builders"). I do think it would be a worthwhile usability improvement on its

Re: KIP-213 - Scalable/Usable Foreign-Key KTable joins - Rebooted.

2018-12-16 Thread Guozhang Wang
John, Thanks a lot for the suggestions on refactoring the wiki, I agree with you that we should consider the KIP proposal to be easily understood by anyone in the future to read, and hence should provide a good summary on the user-facing interfaces, as well as rejected alternatives to represent

[jira] [Created] (KAFKA-7741) Bad dependency via SBT

2018-12-16 Thread sacha barber (JIRA)
sacha barber created KAFKA-7741: --- Summary: Bad dependency via SBT Key: KAFKA-7741 URL: https://issues.apache.org/jira/browse/KAFKA-7741 Project: Kafka Issue Type: Bug Components:

Re: [DISCUSS] KIP-401 TransformerSupplier/ProcessorSupplier enhancements

2018-12-16 Thread Matthias J. Sax
Guozhang, >> Regarding the last option to catch "store exist already" exception and >> fallback to connect stores, I'm a bit concerned it may be hiding actual >> user bugs. I agree with this concern. From my original email: > The only disadvantage I see, might be > potential bugs about sharing