[jira] [Commented] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743718#comment-16743718 ] EverZhang commented on KAFKA-7814: -- {code:java} version: '2' services: kafka: container_

[jira] [Commented] (KAFKA-7827) Consumer stops receiving messages when FIRST leader started is killed

[ https://issues.apache.org/jira/browse/KAFKA-7827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743707#comment-16743707 ] Dhruvil Shah commented on KAFKA-7827: - This is unexpected. How many replicas does the

[jira] [Comment Edited] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743699#comment-16743699 ] Dhruvil Shah edited comment on KAFKA-7814 at 1/16/19 7:00 AM: -

[jira] [Commented] (KAFKA-7814) Broker shut down while cleaning up log file

[ https://issues.apache.org/jira/browse/KAFKA-7814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743699#comment-16743699 ] Dhruvil Shah commented on KAFKA-7814: - [~Ever600686] could you also upload your docke

[jira] [Commented] (KAFKA-6833) KafkaProducer throws "Invalid partition given with record" exception

[ https://issues.apache.org/jira/browse/KAFKA-6833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743566#comment-16743566 ] ASF GitHub Bot commented on KAFKA-6833: --- rayokota commented on pull request #6154:

[jira] [Created] (KAFKA-7828) Add Trogdor ExternalCommandSpec and ExternalCommandWorker

Xi Yang created KAFKA-7828: -- Summary: Add Trogdor ExternalCommandSpec and ExternalCommandWorker Key: KAFKA-7828 URL: https://issues.apache.org/jira/browse/KAFKA-7828 Project: Kafka Issue Type: Impro

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743496#comment-16743496 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6152: KAF

[jira] [Comment Edited] (KAFKA-7820) distinct count kafka streams api

[ https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743479#comment-16743479 ] Boyang Chen edited comment on KAFKA-7820 at 1/16/19 12:09 AM: -

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743481#comment-16743481 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6151: KAF

[jira] [Commented] (KAFKA-7820) distinct count kafka streams api

[ https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743479#comment-16743479 ] Boyang Chen commented on KAFKA-7820: Thanks [~vinubarro] for more details. I think we

[jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743468#comment-16743468 ] Guozhang Wang commented on KAFKA-7497: -- >From the expressiveness of the operators, I

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743464#comment-16743464 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6150: KAF

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743455#comment-16743455 ] ASF GitHub Bot commented on KAFKA-3522: --- mjsax commented on pull request #6149: KAF

[jira] [Created] (KAFKA-7827) Consumer stops receiving messages when FIRST leader started is killed

Somnath Choudhuri created KAFKA-7827: Summary: Consumer stops receiving messages when FIRST leader started is killed Key: KAFKA-7827 URL: https://issues.apache.org/jira/browse/KAFKA-7827 Project:

[jira] [Resolved] (KAFKA-7824) Require member.id for initial join group request

[ https://issues.apache.org/jira/browse/KAFKA-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7824. Resolution: Fixed Fix Version/s: 2.2.0 > Require member.id for initial join group re

[jira] [Commented] (KAFKA-7824) Require member.id for initial join group request

[ https://issues.apache.org/jira/browse/KAFKA-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743408#comment-16743408 ] ASF GitHub Bot commented on KAFKA-7824: --- hachikuji commented on pull request #6058:

[jira] [Commented] (KAFKA-7820) distinct count kafka streams api

[ https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743375#comment-16743375 ] Vinoth Rajasekar commented on KAFKA-7820: - Hey Boyang, That's a good idea and we

[jira] [Updated] (KAFKA-7825) Kafka MirrorMaker crashes unexpectedly

[ https://issues.apache.org/jira/browse/KAFKA-7825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Devilla updated KAFKA-7825: --- Description: I am trying to reproduce production traffic on a test Kafka instance using MirrorMaker.

[jira] [Updated] (KAFKA-7826) Connect Standalone System tests are failing

[ https://issues.apache.org/jira/browse/KAFKA-7826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Magesh kumar Nandakumar updated KAFKA-7826: --- Description: Connect standalone tests are failing since the rest servers are

[jira] [Commented] (KAFKA-7792) Trogdor should have an uptime function

[ https://issues.apache.org/jira/browse/KAFKA-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743350#comment-16743350 ] ASF GitHub Bot commented on KAFKA-7792: --- cmccabe commented on pull request #6130: K

[jira] [Commented] (KAFKA-7826) Connect Standalone System tests are failing

[ https://issues.apache.org/jira/browse/KAFKA-7826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743344#comment-16743344 ] Magesh kumar Nandakumar commented on KAFKA-7826: The issue started with c

[jira] [Created] (KAFKA-7826) Connect Standalone System tests are failing

Magesh kumar Nandakumar created KAFKA-7826: -- Summary: Connect Standalone System tests are failing Key: KAFKA-7826 URL: https://issues.apache.org/jira/browse/KAFKA-7826 Project: Kafka

[jira] [Commented] (KAFKA-6455) Improve timestamp propagation at DSL level

[ https://issues.apache.org/jira/browse/KAFKA-6455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743341#comment-16743341 ] ASF GitHub Bot commented on KAFKA-6455: --- mjsax commented on pull request #6147: KAF

[jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743329#comment-16743329 ] John Roesler commented on KAFKA-7497: - Ah. I was looking at the javadoc on `KStream#j

[jira] [Commented] (KAFKA-7480) GlobalThread should honor custom auto.offset.reset policy

[ https://issues.apache.org/jira/browse/KAFKA-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743325#comment-16743325 ] Matthias J. Sax commented on KAFKA-7480: {quote}Hi [~mjsax], just to confirm the

[jira] [Commented] (KAFKA-7821) Streams: default cache size can lose session windows in high-throughput deployment

[ https://issues.apache.org/jira/browse/KAFKA-7821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743308#comment-16743308 ] Guozhang Wang commented on KAFKA-7821: -- [~MJarvie] Thanks for reporting the issue. M

[jira] [Commented] (KAFKA-7294) Optimize repartitioning for merge()

[ https://issues.apache.org/jira/browse/KAFKA-7294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743293#comment-16743293 ] John Roesler commented on KAFKA-7294: - To clarify, we assume a-priori that all inputs

[jira] [Created] (KAFKA-7825) Kafka MirrorMaker crashes unexpectedly

Joe Devilla created KAFKA-7825: -- Summary: Kafka MirrorMaker crashes unexpectedly Key: KAFKA-7825 URL: https://issues.apache.org/jira/browse/KAFKA-7825 Project: Kafka Issue Type: Bug Co

[jira] [Commented] (KAFKA-7214) Mystic FATAL error

[ https://issues.apache.org/jira/browse/KAFKA-7214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743271#comment-16743271 ] Guozhang Wang commented on KAFKA-7214: -- [~balnpatil] It is still worthwhile to inves

[jira] [Commented] (KAFKA-4113) Allow KTable bootstrap

[ https://issues.apache.org/jira/browse/KAFKA-4113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743260#comment-16743260 ] Edmondo Porcu commented on KAFKA-4113: --  I think we might be experiencing this with

[jira] [Commented] (KAFKA-7480) GlobalThread should honor custom auto.offset.reset policy

[ https://issues.apache.org/jira/browse/KAFKA-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743252#comment-16743252 ] John Roesler commented on KAFKA-7480: - Hi [~mjsax], just to confirm the scope of work

[jira] [Updated] (KAFKA-7824) Require member.id for initial join group request

[ https://issues.apache.org/jira/browse/KAFKA-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7824: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-7610 > Require member.id for initial j

[jira] [Created] (KAFKA-7824) Require member.id for initial join group request

Boyang Chen created KAFKA-7824: -- Summary: Require member.id for initial join group request Key: KAFKA-7824 URL: https://issues.apache.org/jira/browse/KAFKA-7824 Project: Kafka Issue Type: Improv

[jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743249#comment-16743249 ] Matthias J. Sax commented on KAFKA-7497: You understanding seems correct. Also no

[jira] [Commented] (KAFKA-7497) Kafka Streams should support self-join on streams

[ https://issues.apache.org/jira/browse/KAFKA-7497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743225#comment-16743225 ] John Roesler commented on KAFKA-7497: - Thanks [~mjsax], I see that the "key" field i

[jira] [Commented] (KAFKA-7391) Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

[ https://issues.apache.org/jira/browse/KAFKA-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743211#comment-16743211 ] ASF GitHub Bot commented on KAFKA-7391: --- hachikuji commented on pull request #5667:

[jira] [Resolved] (KAFKA-7391) Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)

[ https://issues.apache.org/jira/browse/KAFKA-7391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7391. Resolution: Fixed Fix Version/s: 2.2.0 > Introduce close(Duration) to Producer and A

[jira] [Commented] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

[ https://issues.apache.org/jira/browse/KAFKA-7633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743203#comment-16743203 ] Gavrie Philipson commented on KAFKA-7633: - [~arabelle]: Sorry, but I haven't been

[jira] [Commented] (KAFKA-7075) Allow Topology#addGlobalStore to add a window store

[ https://issues.apache.org/jira/browse/KAFKA-7075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16743104#comment-16743104 ] Tommy Becker commented on KAFKA-7075: - Any update on this?  Would be great to get thi

[jira] [Assigned] (KAFKA-7641) Add `consumer.group.max.size` to cap consumer metadata size on broker

[ https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7641: -- Assignee: Stanislav Kozlovski (was: Boyang Chen) > Add `consumer.group.max.si

[jira] [Commented] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong

[ https://issues.apache.org/jira/browse/KAFKA-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742908#comment-16742908 ] Lars Francke commented on KAFKA-7822: - Sorry, my bad. Yes: 82... > Kafka Log Impleme

[jira] [Updated] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong

[ https://issues.apache.org/jira/browse/KAFKA-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lars Francke updated KAFKA-7822: Description: On this page http://kafka.apache.org/documentation/#log the picture http://kafka.apac

[jira] [Commented] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong

[ https://issues.apache.org/jira/browse/KAFKA-7822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742900#comment-16742900 ] hackerwin7 commented on KAFKA-7822: --- Just should start from 82... ? > Kafka Log Implem

[jira] [Created] (KAFKA-7823) Missing release notes pages

Viktor Somogyi created KAFKA-7823: - Summary: Missing release notes pages Key: KAFKA-7823 URL: https://issues.apache.org/jira/browse/KAFKA-7823 Project: Kafka Issue Type: Improvement Affec

[jira] [Created] (KAFKA-7822) Kafka Log Implementation picture in the documentation is wrong

Lars Francke created KAFKA-7822: --- Summary: Kafka Log Implementation picture in the documentation is wrong Key: KAFKA-7822 URL: https://issues.apache.org/jira/browse/KAFKA-7822 Project: Kafka I

[jira] [Commented] (KAFKA-7149) Reduce assignment data size to improve kafka streams scalability

[ https://issues.apache.org/jira/browse/KAFKA-7149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16742857#comment-16742857 ] Navinder Brar commented on KAFKA-7149: -- [~mjsax] yeah I had submitted a PR, there we