[jira] [Resolved] (KAFKA-3978) Cannot truncate to a negative offset (-1) exception at broker startup

[ https://issues.apache.org/jira/browse/KAFKA-3978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3978. Resolution: Fixed Fix Version/s: 1.2.0 > Cannot truncate to a negative offset (-1) ex

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

Warren, thanks for following up this KIP. And sorry for the "messy" discussion thread. Adding this feature is a little tricky. We still hope to get it into 1.2 release, but atm there is not much progress. However, for your use case, you can replace .map() with .transform() that allows you to acce

Re: [VOTE] 1.1.0 RC2

Hi Damian, Thanks for starting vote thread for 1.1.0 release. There may be a typo on the tag to be voted upon for this release candidate. I guess it should be https://github.com/apache/kafka/tree/1.1.0-rc2 instead of https://github.com/apache/kafka/tree/1.1.0-rc. On Wed, Mar 14, 2018 at 8:27 AM,

Jenkins build is back to normal : kafka-trunk-jdk9 #472

See

Re: [VOTE] 1.1.0 RC2

Hi Damian, Given release plan link in earlier mail is about 1.0 release. You may want to replace that with 1.1.0 release plan link[1]. 1 - https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75957546 Thanks, Satish. On Wed, Mar 14, 2018 at 12:47 AM, Damian Guy wrote: > Hello Kafka

Build failed in Jenkins: kafka-trunk-jdk7 #3252

See Changes: [jason] MINOR: Remove unused server exceptions (#4701) -- [...truncated 1.54 MB...] org.apache.kafka.streams.integration.EosIntegrationTest > shouldNotViola

Re: [DISCUSS] KIP-253: Support in-order message delivery with partition expansion

Hi, Jan, Thanks for sharing your view. I agree with you that recopying the data potentially makes the state management easier since the consumer can just rebuild its state from scratch (i.e., no need for state reshuffling). On the flip slide, I saw a few disadvantages of the approach that you su

[jira] [Created] (KAFKA-6652) The controller should log failed attempts to transition a replica to OfflineReplica state

Lucas Wang created KAFKA-6652: - Summary: The controller should log failed attempts to transition a replica to OfflineReplica state Key: KAFKA-6652 URL: https://issues.apache.org/jira/browse/KAFKA-6652 Pro

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

See Changes: [jason] MINOR: Remove unused server exceptions (#4701) -- [...truncated 416.46 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldReturnUnsupportedIf

[jira] [Created] (KAFKA-6651) SchemaBuilder should not allow Arrays or Maps to be created by type()

Jeremy Custenborder created KAFKA-6651: -- Summary: SchemaBuilder should not allow Arrays or Maps to be created by type() Key: KAFKA-6651 URL: https://issues.apache.org/jira/browse/KAFKA-6651 Proje

[jira] [Created] (KAFKA-6650) The controller should be able to handle a partially deleted topic

Lucas Wang created KAFKA-6650: - Summary: The controller should be able to handle a partially deleted topic Key: KAFKA-6650 URL: https://issues.apache.org/jira/browse/KAFKA-6650 Project: Kafka Is

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

See

Re: Requesting a minor UI change on the documentation page

Hello Raman, Your attached images seems be prevented by apache mailing list, could you upload them to some sharable links and refer them here? Guozhang On Tue, Mar 13, 2018 at 2:53 AM, raman bedi wrote: > Hi Team, > This is rather an insignificant change but will help beginners like me > co

[jira] [Created] (KAFKA-6649) ReplicaFetcher stopped after non fatal exception is thrown

Julio Ng created KAFKA-6649: --- Summary: ReplicaFetcher stopped after non fatal exception is thrown Key: KAFKA-6649 URL: https://issues.apache.org/jira/browse/KAFKA-6649 Project: Kafka Issue Type: Bu

Build failed in Jenkins: kafka-trunk-jdk7 #3251

See Changes: [github] KAFKA-6634: Delay starting new transaction in task.initializeTopology -- [...truncated 1.91 MB...] at hudson.plugins.toolenv.ToolEnvBuildWra

Requesting a minor UI change on the documentation page

Hi Team, This is rather an insignificant change but will help beginners like me coming to your page not getting confused about what links are available to be clicked on the page when watching the video: On the URL: https://kafka.apache.org/0110/documentation/streams/ As you can see, when I hove

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

Hi devs, It's a bit difficult to put all of the pieces together regarding the status and API changes around the KIPs dealing with exposing the record metadata in the Processor and DSL APIs. This is a feature that my team here at American Airlines is keenly interested in and I'd like to provide

[VOTE] 1.1.0 RC2

Hello Kafka users, developers and client-developers, This is the third candidate for release of Apache Kafka 1.1.0. This is minor version release of Apache Kakfa. It Includes 29 new KIPs. Please see the release plan for more details: https://cwiki.apache.org/confluence/pages/viewpage.action?page

Jenkins build is back to normal : kafka-1.1-jdk7 #78

See

[jira] [Created] (KAFKA-6648) Fetcher.getTopicMetadata() only returns "healthy" partitions, not all

radai rosenblatt created KAFKA-6648: --- Summary: Fetcher.getTopicMetadata() only returns "healthy" partitions, not all Key: KAFKA-6648 URL: https://issues.apache.org/jira/browse/KAFKA-6648 Project: Ka

Jenkins build is back to normal : kafka-trunk-jdk7 #3250

See

[jira] [Created] (KAFKA-6647) KafkaStreams.cleanUp creates .lock file in directory its trying to clean

George Bloggs created KAFKA-6647: Summary: KafkaStreams.cleanUp creates .lock file in directory its trying to clean Key: KAFKA-6647 URL: https://issues.apache.org/jira/browse/KAFKA-6647 Project: Kafka

[jira] [Created] (KAFKA-6646) Add a GlobalKStream object type for stream event broadcast

Antony Stubbs created KAFKA-6646: Summary: Add a GlobalKStream object type for stream event broadcast Key: KAFKA-6646 URL: https://issues.apache.org/jira/browse/KAFKA-6646 Project: Kafka Issu

Build failed in Jenkins: kafka-trunk-jdk9 #471

See Changes: [github] KAFKA-6634: Delay starting new transaction in task.initializeTopology -- [...truncated 1.48 MB...] kafka.server.epoch.LeaderEpochFileCacheTest > sho

[jira] [Resolved] (KAFKA-4027) Leader for a cetain partition unavailable forever

[ https://issues.apache.org/jira/browse/KAFKA-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4027. -- Resolution: Duplicate This behavior is changed in KAFKA-5758.  Please reopen if you think the issue sti

Re: [DISCUSS] KIP-257 - Configurable Quota Management

Hi Rajini, Well, I didn't really have specific use cases for having other metadata (like isr and replicas), just thought it would be a more robust interface. But yea, since currently there are no specific use cases, it makes sense not to include them. Viktor On Tue, Mar 13, 2018 at 10:47 AM, Raj

[jira] [Resolved] (KAFKA-6634) Delay initiating the txn on producers until initializeTopology with EOS turned on

[ https://issues.apache.org/jira/browse/KAFKA-6634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6634. -- Resolution: Fixed Fix Version/s: 1.1.0 > Delay initiating the txn on producers until init

Re: [DISCUSS] KIP-255: OAuth Authentication via SASL/OAUTHBEARER

Hi Ron, Thanks for the response. All sound good, I think the only outstanding question is around callbacks vs classes provided through the login context. As you have pointed out, there are advantages of both approaches. Even though my preference is for callbacks, it is not a blocker since the curr

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

See Changes: [rajinisivaram] MINOR: add DEFAULT_PORT for Trogdor Agent and Coordinator (#4674) -- [...truncated 419.52 KB...] kafka.zk.KafkaZkClientTest > testDeleteRecu

Build failed in Jenkins: kafka-trunk-jdk9 #470

See Changes: [rajinisivaram] MINOR: add DEFAULT_PORT for Trogdor Agent and Coordinator (#4674) -- [...truncated 1.48 MB...] kafka.server.epoch.LeaderEpochFileCacheTest >

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

See Changes: [junrao] KAFKA-6624; Prevent concurrent log flush and log deletion (#4663) [jason] KAFKA-6024; Move arg validation in KafkaConsumer ahead of [jason] MINOR: Use large batches in metrics test for con

Build failed in Jenkins: kafka-1.1-jdk7 #77

See Changes: [jason] MINOR: Use large batches in metrics test for conversion time >= 1ms [matthias] MINOR: Streams doc example should not close store (#4667) -- [...truncated

Build failed in Jenkins: kafka-trunk-jdk7 #3249

See Changes: [github] MINOR: Streams doc example should not close store (#4667) -- [...truncated 420.43 KB...] kafka.tools.ConsoleConsumerTest > shouldStopWhenOutputCheck

[jira] [Created] (KAFKA-6645) Sticky Partition Assignment across Kafka Streams application restarts

Giridhar Addepalli created KAFKA-6645: - Summary: Sticky Partition Assignment across Kafka Streams application restarts Key: KAFKA-6645 URL: https://issues.apache.org/jira/browse/KAFKA-6645 Project

Jenkins build is back to normal : kafka-trunk-jdk9 #469

See

Build failed in Jenkins: kafka-trunk-jdk7 #3248

See Changes: [jason] KAFKA-6024; Move arg validation in KafkaConsumer ahead of [jason] MINOR: Use large batches in metrics test for conversion time >= 1ms -- [...truncate

Build failed in Jenkins: kafka-1.0-jdk7 #167

See Changes: [matthias] MINOR: Streams doc example should not close store (#4667) -- [...truncated 374.99 KB...] kafka.message.MessageCompressionTest > testCompressSize PASSE

Re: [DISCUSS] KIP-257 - Configurable Quota Management

I have submitted a PR with the changes proposed in this KIP ( https://github.com/apache/kafka/pull/4699). I added an additional method to the quota callback in the KIP to simplify metrics updates when quotas are updated. Feedback and suggestions are welcome. If there are no other concerns, I will

[jira] [Created] (KAFKA-6644) Make Server Info more generic for Kafka Interactive Queries

Mike Graham created KAFKA-6644: -- Summary: Make Server Info more generic for Kafka Interactive Queries Key: KAFKA-6644 URL: https://issues.apache.org/jira/browse/KAFKA-6644 Project: Kafka Issue

Re: [DISCUSS]KIP-235 DNS alias and secured connections

Hi Jonathan, Thanks for the updates. Looks good to me. You could start voting if there are no other concerns. Regards, Rajini On Fri, Mar 9, 2018 at 6:02 PM, Skrzypek, Jonathan wrote: > Hi, > > There has been further discussion on the ticket and it seems having an > additional option to trigg

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

See Changes: [wangguoz] MINOR: Fix incorrect JavaDoc (type mismatch) (#4632) -- [...truncated 3.52 MB...] kafka.security.auth.SimpleAclAuthorizerTest > testAclManagementA

Build failed in Jenkins: kafka-trunk-jdk9 #468

See Changes: [junrao] KAFKA-6624; Prevent concurrent log flush and log deletion (#4663) -- [...truncated 1.48 MB...] kafka.controller.PartitionStateMachineTest > testInval

Build failed in Jenkins: kafka-1.1-jdk7 #76

See Changes: [junrao] KAFKA-6624; Prevent concurrent log flush and log deletion (#4663) -- [...truncated 416.73 KB...] kafka.controller.PartitionStateMachineTest > testOffli