[jira] [Created] (KAFKA-6789) Add retry logic in AdminClient requests

Guozhang Wang created KAFKA-6789: Summary: Add retry logic in AdminClient requests Key: KAFKA-6789 URL: https://issues.apache.org/jira/browse/KAFKA-6789 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6788) Grouping consumer requests per consumer coordinator in admin client

Guozhang Wang created KAFKA-6788: Summary: Grouping consumer requests per consumer coordinator in admin client Key: KAFKA-6788 URL: https://issues.apache.org/jira/browse/KAFKA-6788 Project: Kafka

[jira] [Created] (KAFKA-6787) enumerate SampledStat.samples got null item

Qiang Zhao created KAFKA-6787: - Summary: enumerate SampledStat.samples got null item Key: KAFKA-6787 URL: https://issues.apache.org/jira/browse/KAFKA-6787 Project: Kafka Issue Type: Bug

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

See Changes: [jason] KAFKA-6234; Increased timeout value for lowWatermark response to fix -- [...truncated 3.53 MB...] kafka.security.auth.SimpleAclAuthorizerTest >

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

See Changes: [jason] KAFKA-6234; Increased timeout value for lowWatermark response to fix -- [...truncated 411.22 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

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

See Changes: [jason] KAFKA-6234; Increased timeout value for lowWatermark response to fix -- [...truncated 1.48 MB...] kafka.server.epoch.LeaderEpochFileCacheTest >

[jira] [Created] (KAFKA-6786) Remove additional configs in StreamsStandbyTask

Guozhang Wang created KAFKA-6786: Summary: Remove additional configs in StreamsStandbyTask Key: KAFKA-6786 URL: https://issues.apache.org/jira/browse/KAFKA-6786 Project: Kafka Issue Type:

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

See

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

See Changes: [github] MINOR: Disable failing testDescribeConsumerGroupOffsets test case -- [...truncated 411.57 KB...] kafka.controller.ControllerFailoverTest >

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

See

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

See Changes: [wangguoz] KAFKA-6592: ConsoleConsumer should support WindowedSerdes (#4797) -- [...truncated 1.45 MB...] org.apache.kafka.common.metrics.MetricsTest >

[jira] [Created] (KAFKA-6785) Add Trogdor documentation

Colin P. McCabe created KAFKA-6785: -- Summary: Add Trogdor documentation Key: KAFKA-6785 URL: https://issues.apache.org/jira/browse/KAFKA-6785 Project: Kafka Issue Type: Improvement

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

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

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

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

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

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

Re: [DISCUSS] KIP-276: Add StreamsConfig prefix for different consumers

Thanks Ewen and Matthias for the explanation. I'm also in favor of the current proposal, and my rationale are basically 1) inheritance hierarchy is simple for users to understand (Matthias has explained it well), 2) for normal users they only need to have the base consumer configs specification.

Re: [DISCUSS] KIP-285: Connect Rest Extension Plugin

Hi Randall, Thanks a lot for your feedback. I will update the KIP to reflect your comments in (1), (2), (7) and (8). For comment # (3) , while it would be great to automatically configure the Rest Extensions, I would prefer that to be specified explicitly. Lets assume a connector archive

Re: [DISCUSS] KIP-283: Efficient Memory Usage for Down-Conversion

Thanks Dhruvil. That makes sense. On Thu, Apr 12, 2018 at 2:49 AM, Dhruvil Shah wrote: > Hi Rajini, > > Thanks for the comments. > > Which config parameters are these referring to? > > This refers to a proposal that was later rejected. I have removed this goal > from the

Re: Support Cast of LogicalTypes to String

Can one of the maintainers who handles Connect and SMTs checkout my ticket and PR please? Thanks, Amit On Wed, Apr 4, 2018 at 2:37 PM Amit Sela wrote: > I've created a ticket - https://issues.apache.org/jira/browse/KAFKA-6684 > and PR -

[jira] [Resolved] (KAFKA-4373) Kafka Consumer API jumping offsets

[ https://issues.apache.org/jira/browse/KAFKA-4373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4373. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen if you think the issue still exists

[jira] [Resolved] (KAFKA-2284) ConsumerRebalanceListener receives wrong type in partitionOwnership values

[ https://issues.apache.org/jira/browse/KAFKA-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2284. -- Resolution: Auto Closed The Scala consumers have been deprecated and no further work is planned, please

[jira] [Resolved] (KAFKA-4347) outputStreamId in Kafka spout

[ https://issues.apache.org/jira/browse/KAFKA-4347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4347. -- Resolution: Invalid Looks like this is related to Apache Storm Kafka connector. Request you raise the

[jira] [Resolved] (KAFKA-4124) Handle disk failures gracefully

[ https://issues.apache.org/jira/browse/KAFKA-4124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4124. -- Resolution: Duplicate Some of these requirements are implemented in KIP-112/KIP-113. Pls raise new

[jira] [Created] (KAFKA-6784) FindCoordinatorResponse cannot be cast to FetchResponse

Qiang Zhao created KAFKA-6784: - Summary: FindCoordinatorResponse cannot be cast to FetchResponse Key: KAFKA-6784 URL: https://issues.apache.org/jira/browse/KAFKA-6784 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6783) consumer poll(timeout) blocked infinitely when no available bootstrap server

Qiang Zhao created KAFKA-6783: - Summary: consumer poll(timeout) blocked infinitely when no available bootstrap server Key: KAFKA-6783 URL: https://issues.apache.org/jira/browse/KAFKA-6783 Project: Kafka

[jira] [Resolved] (KAFKA-611) Migration tool and Mirror Maker ignore mirror.topics.whitelist in config

[ https://issues.apache.org/jira/browse/KAFKA-611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-611. - Resolution: Auto Closed mirror.topics.whitelist/blacklist were part of old consumer. also these configs

[jira] [Resolved] (KAFKA-2339) broker becomes unavailable if bad data is passed through the protocol

[ https://issues.apache.org/jira/browse/KAFKA-2339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2339. -- Resolution: Cannot Reproduce Not able to reproduce on latest server. Please reopen if you think the

[jira] [Resolved] (KAFKA-2302) Currently iterated chunk is not cleared during consumer shutdown

[ https://issues.apache.org/jira/browse/KAFKA-2302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2302. -- Resolution: Auto Closed Closing inactive issue. The old consumer is no longer supported, please upgrade

[jira] [Resolved] (KAFKA-1643) message.send.max.retries not respected when no brokers are up

[ https://issues.apache.org/jira/browse/KAFKA-1643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1643. -- Resolution: Auto Closed The Scala producers have been deprecated for a while and no further work is

[jira] [Resolved] (KAFKA-1405) Global JSON.globalNumberParser screws up other libraries

[ https://issues.apache.org/jira/browse/KAFKA-1405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1405. -- Resolution: Fixed Old Scala JSON usage is removed in new versions of Kafka > Global

Re: [DISCUSS] KIP-284 Set default retention ms for Streams repartition topics to Long.MAX_VALUE

Hi guys, We got 3 (+1) and 3 (+1 binding), 72 hours passed, i'll update the kip as accepted Thanks. 2018-04-09 9:27 GMT+01:00 Ted Yu : > I think we can. > Original message From: khaireddine Rezgui < > khaireddine...@gmail.com> Date: 4/9/18 1:12 AM

Re: [DISCUSS] KIP-286: producer.send() should not block on metadata update

Hey Ted, Thanks for your comments. With the proposed solution in the KIP, the memory is only allocated once for the given message, which is the same as the existing implementation. The serialized message will be moved from per-topic queue to per-partition queue without incurring additional memory

Re: [VOTE] KIP-270 A Scala wrapper library for Kafka Streams

Thanks for the KIP Debasish - +1 binding On Wed, 11 Apr 2018 at 12:16 Ted Yu wrote: > +1 > Original message From: Debasish Ghosh < > debasish.gh...@lightbend.com> Date: 4/11/18 3:09 AM (GMT-08:00) To: > dev@kafka.apache.org Subject: [VOTE] KIP-270 A Scala

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

See

[jira] [Created] (KAFKA-6782) GlobalStateStore never finishes restoring when consuming transactional messages

Lingxiao WANG created KAFKA-6782: Summary: GlobalStateStore never finishes restoring when consuming transactional messages Key: KAFKA-6782 URL: https://issues.apache.org/jira/browse/KAFKA-6782

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

See