[jira] [Assigned] (KAFKA-3058) remove the usage of deprecated config properties

[ https://issues.apache.org/jira/browse/KAFKA-3058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konrad Kalita reassigned KAFKA-3058: Assignee: Konrad Kalita > remove the usage of deprecated config properties >

Re: KIP-41: KafkaConsumer Max Records

Hi Cliff, I think we're all agreed that the current contract of poll() should be kept. The consumer wouldn't wait for max messages to become available in this proposal; it would only sure that it never returns more than max messages. -Jason On Mon, Jan 4, 2016 at 11:52 AM, Cliff Rhyne

Re: [VOTE] KIP-32 Add CreateTime and LogAppendTime to Kafka message.

Hey Becket/Anna - I have a few comments about the KIP. 1. (Minor) Can we rename the KIP? It's currently "Add CreateTime and LogAppendTime etc..". This is actually the title of the now rejected Option 1. 2. (Minor) Can we rename the proposed option? It isn't really "option 4" anymore. 3. I'm not

[jira] [Updated] (KAFKA-3051) security.protocol documentation is inaccurate

[ https://issues.apache.org/jira/browse/KAFKA-3051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3051: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 724

[GitHub] kafka pull request: KAFKA-3051 KAFKA-3048; Security config docs im...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/724 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request: MINOR: Update version to 0.9.0.1-SNAPSHOT

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/727 MINOR: Update version to 0.9.0.1-SNAPSHOT You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka minor-0.9.0.1-SNAPSHOT Alternatively you

Re: KIP-41: KafkaConsumer Max Records

I can't speak to all use-cases, but for the database one, I think pause-resume will be necessary in any case, and therefore dynamic batch sizes are not needed. Databases are really unexpected regarding response times - load and locking can affect this. I'm not sure there's a good way to know you

Re: KIP-41: KafkaConsumer Max Records

My team's main use-case benefits from flexibility between consumers, which both options handle well. If the poll timeout triggers before the full batch size, I'd still want to get whatever is available. On Mon, Jan 4, 2016 at 12:49 PM, Gwen Shapira wrote: > I can't speak to

[GitHub] kafka pull request: KAFKA-2422: Allow copycat connector plugins to...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/687 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-3051) security.protocol documentation is inaccurate

[ https://issues.apache.org/jira/browse/KAFKA-3051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081780#comment-15081780 ] ASF GitHub Bot commented on KAFKA-3051: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-3048) incorrect property name ssl.want.client.auth

[ https://issues.apache.org/jira/browse/KAFKA-3048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3048: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 724

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

See Changes: [me] KAFKA-2422: Allow copycat connector plugins to be aliased to simpler -- [...truncated 4758 lines...] org.apache.kafka.connect.runtime.WorkerTest > testStopInvalidConnector

Re: KIP-41: KafkaConsumer Max Records

Gwen and Ismael, I agree the configuration option is probably the way to go, but I was wondering whether there would be cases where it made sense to let the consumer dynamically set max messages to adjust for downstream slowness. For example, if the consumer is writing consumed records to another

Re: KIP-41: KafkaConsumer Max Records

Instead of a heartbeat, I'd prefer poll() to return whatever messages the client has. Either a) I don't care if I get less than my max message limit or b) I do care and will set a larger timeout. Case B is less common than A and is fairly easy to handle in the application's code. On Mon, Jan 4,

[jira] [Resolved] (KAFKA-2884) Schema cache corruption in JsonConverter

[ https://issues.apache.org/jira/browse/KAFKA-2884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2884. -- Resolution: Duplicate Oops, seems when KAFKA-3055 was filed we missed that we

Re: KIP-41: KafkaConsumer Max Records

Hey Gwen, I was thinking along the lines of TCP window scaling in order to dynamically find a good consumption rate. Basically you'd start off consuming say 100 records and you'd let it increase until the consumption took longer than half the session timeout (for example). You /might/ be able to

[jira] [Commented] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

[ https://issues.apache.org/jira/browse/KAFKA-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081693#comment-15081693 ] ASF GitHub Bot commented on KAFKA-2422: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

[ https://issues.apache.org/jira/browse/KAFKA-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2422. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request

[GitHub] kafka pull request: MINOR: Add secondary constructor that takes on...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/728 MINOR: Add secondary constructor that takes only `props` in `KafkaConfig` This fixes a compatibility break for users that use `new KafkaConfig(map)` instead of `KafkaConfig(map)`. You can merge

[jira] [Commented] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081756#comment-15081756 ] Stevo Slavic commented on KAFKA-3059: - KAFKA-3057 was earlier created to fix related documentation. >

Re: KIP-41: KafkaConsumer Max Records

1. Agree that TCP window style scaling will be cool. I'll try to think of a good excuse to use it ;) 2. I'm very concerned about the challenges of getting the timeouts, hearbeats and max messages right. Another option could be to expose "heartbeat" API to consumers. If my app is still processing

[GitHub] kafka pull request: MINOR: Add secondary constructor that takes on...

Github user ijuma closed the pull request at: https://github.com/apache/kafka/pull/728 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-3051) security.protocol documentation is inaccurate

[ https://issues.apache.org/jira/browse/KAFKA-3051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081028#comment-15081028 ] ASF GitHub Bot commented on KAFKA-3051: --- GitHub user ijuma opened a pull request:

[GitHub] kafka pull request: KAFKA-3051 KAFKA-3048; Security config docs im...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/724 KAFKA-3051 KAFKA-3048; Security config docs improvements You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka minor-security-fixes

[jira] [Updated] (KAFKA-3051) security.protocol documentation is inaccurate

[ https://issues.apache.org/jira/browse/KAFKA-3051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3051: --- Reviewer: Jun Rao Status: Patch Available (was: Open) > security.protocol documentation is

[jira] [Created] (KAFKA-3057) "Checking consumer position" docs are referencing (only) deprecated ConsumerOffsetChecker

Stevo Slavic created KAFKA-3057: --- Summary: "Checking consumer position" docs are referencing (only) deprecated ConsumerOffsetChecker Key: KAFKA-3057 URL: https://issues.apache.org/jira/browse/KAFKA-3057

[jira] [Assigned] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3052: -- Assignee: Ismael Juma > broker properties get logged twice if acl is enabled >

[jira] [Updated] (KAFKA-3048) incorrect property name ssl.want.client.auth

[ https://issues.apache.org/jira/browse/KAFKA-3048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3048: --- Reviewer: Jun Rao Status: Patch Available (was: Open) PR (which also includes KAFKA-3051):

[jira] [Comment Edited] (KAFKA-3062) Read from kafka replication to get data likely Version based

[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081989#comment-15081989 ] xingang edited comment on KAFKA-3062 at 1/4/16 11:45 PM: - "Likely version based"

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

See Changes: [me] KAFKA-2422: Allow copycat connector plugins to be aliased to simpler -- [...truncated 4753 lines...] org.apache.kafka.connect.storage.KafkaConfigStorageTest > testRestore

[GitHub] kafka pull request: KAFKA-2937 : Disable the leaderIsr check if th...

GitHub user MayureshGharat opened a pull request: https://github.com/apache/kafka/pull/729 KAFKA-2937 : Disable the leaderIsr check if the topic is to be deleted. The check was implemented in KAFKA-340 : If we are shutting down a broker when the ISR of a partition includes only

[jira] [Commented] (KAFKA-3062) Read from kafka replication to get data likely Version based

[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082004#comment-15082004 ] xingang commented on KAFKA-3062: Yes! Example: Huge volume data producing to >60 partition, and 15

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081958#comment-15081958 ] ASF GitHub Bot commented on KAFKA-2937: --- GitHub user MayureshGharat opened a pull request:

[jira] [Comment Edited] (KAFKA-3062) Read from kafka replication to get data likely Version based

[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082004#comment-15082004 ] xingang edited comment on KAFKA-3062 at 1/4/16 11:30 PM: - Yes! Example: Huge

[jira] [Commented] (KAFKA-3062) Read from kafka replication to get data likely Version based

[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081989#comment-15081989 ] xingang commented on KAFKA-3062: "Likely version based" means: 1) it's Ok for such None-Latency consumers

[VOTE] KIP-36 - Rack aware replica assignment

I would like to call for a vote for KIP-36 - Rack aware replica assignment. The latest proposal is at https://cwiki.apache.org/confluence/display/KAFKA/KIP-36 +Rack+aware+replica+assignment Thanks, Allen

[jira] [Created] (KAFKA-3060) Refactor MeteredXXStore

Yasuhiro Matsuda created KAFKA-3060: --- Summary: Refactor MeteredXXStore Key: KAFKA-3060 URL: https://issues.apache.org/jira/browse/KAFKA-3060 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-3062) Read from kafka replication to get data likely Version based

[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081987#comment-15081987 ] Mayuresh Gharat commented on KAFKA-3062: Hi [~itismewxg], can you explain the usecase here with an

[jira] [Comment Edited] (KAFKA-3062) Read from kafka replication to get data likely Version based

[ https://issues.apache.org/jira/browse/KAFKA-3062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082004#comment-15082004 ] xingang edited comment on KAFKA-3062 at 1/4/16 11:31 PM: - Yes! Example: Huge

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

See Changes: [junrao] KAFKA-3051 KAFKA-3048; Security config docs improvements -- [...truncated 3364 lines...] org.apache.kafka.clients.NetworkClientTest > testClose PASSED

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

See Changes: [junrao] KAFKA-3051 KAFKA-3048; Security config docs improvements -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-6 (docker

[jira] [Created] (KAFKA-3062) Read from kafka replication to get data likely Version based

xingang created KAFKA-3062: -- Summary: Read from kafka replication to get data likely Version based Key: KAFKA-3062 URL: https://issues.apache.org/jira/browse/KAFKA-3062 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3016) Add KStream-KStream window joins

[ https://issues.apache.org/jira/browse/KAFKA-3016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082117#comment-15082117 ] Guozhang Wang commented on KAFKA-3016: -- [~yasuhiro.matsuda] I'm leaving this ticket as in progress

[jira] [Updated] (KAFKA-3016) Add KStream-KStream window joins

[ https://issues.apache.org/jira/browse/KAFKA-3016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3016: - Status: In Progress (was: Patch Available) > Add KStream-KStream window joins >

[jira] [Assigned] (KAFKA-3045) ZkNodeChangeNotificationListener shouldn't log interrupted exception as error

[ https://issues.apache.org/jira/browse/KAFKA-3045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned KAFKA-3045: --- Assignee: Dong Lin > ZkNodeChangeNotificationListener shouldn't log interrupted exception as error >

[GitHub] kafka pull request: KAFKA-3045; ZkNodeChangeNotificationListener s...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/731 KAFKA-3045; ZkNodeChangeNotificationListener shouldn't log InterruptedException as error You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (KAFKA-3016) Add KStream-KStream window joins

[ https://issues.apache.org/jira/browse/KAFKA-3016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3016: - Status: Patch Available (was: Open) > Add KStream-KStream window joins >

[GitHub] kafka pull request: KAFKA-2653: Alternative Kafka Streams Stateful...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/730 KAFKA-2653: Alternative Kafka Streams Stateful API Design ping @ymatsuda for reviews. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-2653) Stateful operations in the KStream DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-2653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082183#comment-15082183 ] ASF GitHub Bot commented on KAFKA-2653: --- GitHub user guozhangwang opened a pull request:

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

See Changes: [wangguoz] KAFKA-3016: phase-1. A local store for join window -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docker

[jira] [Commented] (KAFKA-3064) Improve resync method to waste less time and data transfer

[ https://issues.apache.org/jira/browse/KAFKA-3064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082367#comment-15082367 ] Dong Lin commented on KAFKA-3064: - [~Skandragon], can you clarify why consumer would throw away data,

[jira] [Created] (KAFKA-3064) Improve resync method to waste less time and data transfer

Michael Graff created KAFKA-3064: Summary: Improve resync method to waste less time and data transfer Key: KAFKA-3064 URL: https://issues.apache.org/jira/browse/KAFKA-3064 Project: Kafka

[GitHub] kafka pull request: MINOR: ignore subproject .gitignore file for e...

Github user vesense closed the pull request at: https://github.com/apache/kafka/pull/389 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Comment Edited] (KAFKA-3064) Improve resync method to waste less time and data transfer

[ https://issues.apache.org/jira/browse/KAFKA-3064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15082367#comment-15082367 ] Dong Lin edited comment on KAFKA-3064 at 1/5/16 4:44 AM: - [~Skandragon], can you

[jira] [Commented] (KAFKA-3057) "Checking consumer position" docs are referencing (only) deprecated ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-3057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081104#comment-15081104 ] Jens Rantil commented on KAFKA-3057: Also, should the documentation also document how to check the

[jira] [Commented] (KAFKA-3057) "Checking consumer position" docs are referencing (only) deprecated ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-3057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081128#comment-15081128 ] Stevo Slavic commented on KAFKA-3057: - [~ztyx] that is covered already on wiki page:

Re: KIP-41: KafkaConsumer Max Records

Hi guys, I realized I never thanked yall for your input - thanks! Jason: I apologize for assuming your stance on the issue! Feels like we all agreed on the solution. +1 Follow-up: Jason made a point about defining prefetch and fairness behaviour in the KIP. I am now working on putting that down

[jira] [Updated] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-2072: --- Status: Patch Available (was: In Progress) > Add StopReplica request/response to

[GitHub] kafka pull request: KAFKA-3058: remove the usage of deprecated con...

GitHub user konradkalita opened a pull request: https://github.com/apache/kafka/pull/732 KAFKA-3058: remove the usage of deprecated config properties You can merge this pull request into a Git repository by running: $ git pull https://github.com/konradkalita/kafka Kafka-3058

[jira] [Updated] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot updated KAFKA-2072: --- Status: In Progress (was: Patch Available) > Add StopReplica request/response to

[jira] [Commented] (KAFKA-3045) ZkNodeChangeNotificationListener shouldn't log interrupted exception as error

[ https://issues.apache.org/jira/browse/KAFKA-3045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081237#comment-15081237 ] Ismael Juma commented on KAFKA-3045: AclChangedNotificationHandler also has a similar issue. Both

[GitHub] kafka pull request: KAFKA-3052; Broker properties get logged twice...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/725 KAFKA-3052; Broker properties get logged twice if acl enabled Fix it by making it possible to pass the `doLog` parameter to `AbstractConfig`. As explained in the code comments, this means that we can

[jira] [Commented] (KAFKA-3050) Space in the value for "host.name" causes "Unresolved address"

[ https://issues.apache.org/jira/browse/KAFKA-3050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081233#comment-15081233 ] Ismael Juma commented on KAFKA-3050: Thanks for the report. To be clear, are you requesting that we

[jira] [Updated] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3052: --- Reviewer: Gwen Shapira Status: Patch Available (was: Open) > broker properties get logged

[jira] [Commented] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081217#comment-15081217 ] ASF GitHub Bot commented on KAFKA-3052: --- GitHub user ijuma opened a pull request:

[jira] [Resolved] (KAFKA-3041) NullPointerException in new Consumer API on broker restart

[ https://issues.apache.org/jira/browse/KAFKA-3041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3041. Resolution: Duplicate Assignee: Jason Gustafson (was: Neha Narkhede) > NullPointerException

[GitHub] kafka pull request: KAFKA-3052; Broker properties get logged twice...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/725 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Created] (KAFKA-3058) remove the usage of deprecated config properties

Jun Rao created KAFKA-3058: -- Summary: remove the usage of deprecated config properties Key: KAFKA-3058 URL: https://issues.apache.org/jira/browse/KAFKA-3058 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

[ https://issues.apache.org/jira/browse/KAFKA-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3055. -- Resolution: Fixed Fix Version/s: 0.9.1.0 0.9.0.1

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081352#comment-15081352 ] Mayuresh Gharat commented on KAFKA-2937: [~djh] does your integration test check if the topic is

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

See Changes: [me] KAFKA-3055; Fix JsonConverter mangling the Schema in Connect [wangguoz] KAFKA-3052; Broker properties get logged twice if acl enabled -- Started by an SCM change [EnvInject] -

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081401#comment-15081401 ] Henri Pihkala commented on KAFKA-2937: -- [~mgharat] Yes, like this: AdminUtils.createTopic(...)

[jira] [Created] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

Gwen Shapira created KAFKA-3059: --- Summary: ConsumerGroupCommand should allow resetting offsets for consumer groups Key: KAFKA-3059 URL: https://issues.apache.org/jira/browse/KAFKA-3059 Project: Kafka

[jira] [Created] (KAFKA-3061) Get rid of Guava dependency

Gwen Shapira created KAFKA-3061: --- Summary: Get rid of Guava dependency Key: KAFKA-3061 URL: https://issues.apache.org/jira/browse/KAFKA-3061 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081910#comment-15081910 ] Mayuresh Gharat commented on KAFKA-2937: Yes, that might be possible but it should be rare. The

[jira] [Assigned] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-3059: -- Assignee: Jason Gustafson > ConsumerGroupCommand should allow resetting offsets for

Re: KIP-41: KafkaConsumer Max Records

The wiki you pointed to is no longer maintained and fell out of sync with the code and protocol. You may want to refer to: https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol On Mon, Jan 4, 2016 at 4:38 AM, Jens Rantil wrote: > Hi guys, > > I

[GitHub] kafka pull request: KAFKA-3016: phase-1. A local store for join wi...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/726 KAFKA-3016: phase-1. A local store for join window @guozhangwang An implementation of local store for join window. This implementation uses "rolling" of RocksDB instances for timestamp based

[jira] [Commented] (KAFKA-3016) Add KStream-KStream window joins

[ https://issues.apache.org/jira/browse/KAFKA-3016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081461#comment-15081461 ] ASF GitHub Bot commented on KAFKA-3016: --- GitHub user ymatsuda opened a pull request:

[jira] [Commented] (KAFKA-3059) ConsumerGroupCommand should allow resetting offsets for consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-3059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081466#comment-15081466 ] Jason Gustafson commented on KAFKA-3059: Would this call for a new request API (e.g. DeleteGroup

[jira] [Updated] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3052: --- Reviewer: Guozhang Wang (was: Gwen Shapira) > broker properties get logged twice if acl is enabled >

[jira] [Commented] (KAFKA-3054) Connect Herder fail forever if sent a wrong connector config or task config

[ https://issues.apache.org/jira/browse/KAFKA-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081370#comment-15081370 ] Ewen Cheslack-Postava commented on KAFKA-3054: -- [~jinxing6...@126.com] Yes, this sounds like

[jira] [Commented] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

[ https://issues.apache.org/jira/browse/KAFKA-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081345#comment-15081345 ] ASF GitHub Bot commented on KAFKA-3055: --- Github user asfgit closed the pull request at:

[jira] [Commented] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081349#comment-15081349 ] ASF GitHub Bot commented on KAFKA-3052: --- Github user asfgit closed the pull request at:

[jira] [Updated] (KAFKA-3052) broker properties get logged twice if acl is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3052: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request

[GitHub] kafka pull request: KAFKA-3055: Fix the JsonConverter mangling the...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/722 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-3040) Broker didn't report new data after change in leader

[ https://issues.apache.org/jira/browse/KAFKA-3040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081519#comment-15081519 ] Mayuresh Gharat commented on KAFKA-3040: At Linkedin, we do have a separate controller log file on