Jenkins build is back to normal : kafka-2.0-jdk8 #146

See

Jenkins build is back to normal : kafka-trunk-jdk8 #2981

See

Jenkins build is back to normal : kafka-trunk-jdk10 #513

See

Build failed in Jenkins: kafka-trunk-jdk8 #2980

See Changes: [mjsax] MINOR: rename InternalProcessorContext.initialized (#5672) -- [...truncated 2.33 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [VOTE] KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde

If I understand the way that this works in light of KIP-331, all the methods of Serializer, for example, will have defaults except for : "byte[] serialize(String topic, T data);" This means that I could supply a serializer like this: "(topic, myData) -> myData.toByteArrayOrWhatever()", right?

Build failed in Jenkins: kafka-trunk-jdk10 #512

See Changes: [junrao] KAFKA-7400: Compacted topic segments that precede the log start offse… [junrao] KAFKA-7216: Ignore unknown ResourceTypes while loading acl cache (#5673)

RE: [DISCUSS] KIP-280: Enhanced log compaction

Someone pointed out to me that my scenario is also resolved by using Kafka transactions. Zombie fencing which is essentially my scenario was one of the scenarios that transactions were designed to solve. I was going to use the ideas of this KIP to solve it but using transactions seems even

[jira] [Resolved] (KAFKA-7400) Compacted topic segments that precede the log start offset are not cleaned up

[ https://issues.apache.org/jira/browse/KAFKA-7400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7400. Resolution: Fixed Fix Version/s: 2.1.0 Merged the PR to trunk. > Compacted topic segments that

Build failed in Jenkins: kafka-trunk-jdk10 #511

See Changes: [mjsax] MINOR: rename InternalProcessorContext.initialized (#5672) -- [...truncated 1.40 MB...] org.apache.kafka.connect.transforms.RegexRouterTest >

Build failed in Jenkins: kafka-trunk-jdk8 #2979

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-eu2 (ubuntu trusty) in workspace

[jira] [Created] (KAFKA-7430) Improve Transformer interface JavaDoc

Eugen Feller created KAFKA-7430: --- Summary: Improve Transformer interface JavaDoc Key: KAFKA-7430 URL: https://issues.apache.org/jira/browse/KAFKA-7430 Project: Kafka Issue Type: Improvement

Re: [DISCUSS] KIP-221: Repartition Topic Hints in Streams

Hi, Just want to know is anyone actively working on this and also KAFKA-4835 ? Seems like the JIRA has been inactive for couple months. We want this feature and would like to move it forward if no one else is working on it. Lei On Wed, Jun 20,

[jira] [Resolved] (KAFKA-7425) Kafka Broker -Unable to start

[ https://issues.apache.org/jira/browse/KAFKA-7425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7425. -- Resolution: Duplicate will handle this as part of KAFKA-7216. > Kafka Broker -Unable to start >

Re: Issue in Creating the Kafka Consumer

Hi Sravanthi, Do I understand correctly that you pass the path to your JAAS configuration file to the JVM via a system property (e.g -Djava.security.auth.login.config=/path_to_your_directory/jaas.conf )? >From the error message: > Caused by: _java.lang.IllegalArgumentException_: No serviceName

Re: [VOTE] KIP 368: Allow SASL Connections to Periodically Re-Authenticate

+1 (non-binding) Thanks for the KIP, this is a very nice feature. On Fri, Sep 21, 2018 at 4:56 PM Stanislav Kozlovski wrote: > > Thanks for the KIP, Ron! > +1 (non-binding) > > On Fri, Sep 21, 2018 at 5:26 PM Ron Dagostino wrote: > > > Hi Everyone. This KIP requires 1 more binding up-vote to be

Re: [VOTE] KIP 368: Allow SASL Connections to Periodically Re-Authenticate

Thanks for the KIP, Ron! +1 (non-binding) On Fri, Sep 21, 2018 at 5:26 PM Ron Dagostino wrote: > Hi Everyone. This KIP requires 1 more binding up-vote to be considered for > the 2.1.0 release; please vote before the Monday deadline. > > The current vote is 2 binding +1 votes (Rajini and

Re: [VOTE] KIP 368: Allow SASL Connections to Periodically Re-Authenticate

Hi Everyone. This KIP requires 1 more binding up-vote to be considered for the 2.1.0 release; please vote before the Monday deadline. The current vote is 2 binding +1 votes (Rajini and Harsha) and 5 non-binding +1 votes (myself, Mike, Konstantin, Boerge, and Edoardo). Ron On Wed, Sep 19, 2018

Re: [VOTE] KIP-371: Add a configuration to build custom SSL principal name

Hi Manikumar, Thanks for the KIP! +1 (binding) On Thu, Sep 20, 2018 at 8:53 PM, Priyank Shah wrote: > +1(non-binding) > > On 9/20/18, 9:18 AM, "Harsha Chintalapani" wrote: > > +1 (binding). > > Thanks, > Harsha > > > On September 19, 2018 at 5:19:51 AM, Manikumar ( >

[jira] [Created] (KAFKA-7429) Enable dynamic key/truststore update with same filename/password

Rajini Sivaram created KAFKA-7429: - Summary: Enable dynamic key/truststore update with same filename/password Key: KAFKA-7429 URL: https://issues.apache.org/jira/browse/KAFKA-7429 Project: Kafka

[DISCUSS] KIP-374: Add '--help' option to all available Kafka CLI commands

Hi All, I'd like to start a discussion on KIP-374 which is to add "--help" option for all the possible CLI commands in Kafka. right now, few commands support it and few does not. We brings up this KIP to provide consistent user experience. More details added in this KIP page(including code