Re: [DISCUSS] KIP-208: Add SSL support to Kafka Connect REST interface

FYI: Based on Ewen's suggestion from the related JIRA, I added a clarification to the KIP that it doesn't do anything around authorization / ACLs. While authorization / ACLs would be for sure valuable feature I would prefer to leave it for different KIP. Jakub On Mon, Oct 9, 2017 at 5:25 PM, Jaku

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

See Changes: [ismael] KAFKA-6026; Fix for indefinite wait in KafkaFutureImpl -- [...truncated 207.67 KB...] kafka.api.PlaintextConsumerTest > testRoundRobinAssignment STARTED

[jira] [Created] (KAFKA-6040) Expose topic size for monitoring

Michael Andre Pearce created KAFKA-6040: --- Summary: Expose topic size for monitoring Key: KAFKA-6040 URL: https://issues.apache.org/jira/browse/KAFKA-6040 Project: Kafka Issue Type: New

[jira] [Created] (KAFKA-6041) "--producer.config" option doesn't work

Phoenix_Dad created KAFKA-6041: -- Summary: "--producer.config" option doesn't work Key: KAFKA-6041 URL: https://issues.apache.org/jira/browse/KAFKA-6041 Project: Kafka Issue Type: Bug C

[GitHub] kafka pull request #4050: KAFKA-6041: "--producer.config" option doesn't wor...

GitHub user wujianping10043419 opened a pull request: https://github.com/apache/kafka/pull/4050 KAFKA-6041: "--producer.config" option doesn't work" The configured parameters in the config\producer.properties file will be overwritten by the parameter default values. For exa

[jira] [Created] (KAFKA-6042) Kafka Request Handler deadlocks and brings down the cluster.

Ben Corlett created KAFKA-6042: -- Summary: Kafka Request Handler deadlocks and brings down the cluster. Key: KAFKA-6042 URL: https://issues.apache.org/jira/browse/KAFKA-6042 Project: Kafka Issue

[jira] [Created] (KAFKA-6043) Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked

Ramkumar created KAFKA-6043: --- Summary: Kafka 8.1.1 - .ZookeeperConsumerConnector.shutdown(ZookeeperConsumerConnector.scala:110) blocked Key: KAFKA-6043 URL: https://issues.apache.org/jira/browse/KAFKA-6043

[jira] [Created] (KAFKA-6044) Unable to start broker after ungraceful shutdown on windows

Niels Hoogeveen created KAFKA-6044: -- Summary: Unable to start broker after ungraceful shutdown on windows Key: KAFKA-6044 URL: https://issues.apache.org/jira/browse/KAFKA-6044 Project: Kafka

[jira] [Created] (KAFKA-6045) All access to log should fail if log is closed

Dong Lin created KAFKA-6045: --- Summary: All access to log should fail if log is closed Key: KAFKA-6045 URL: https://issues.apache.org/jira/browse/KAFKA-6045 Project: Kafka Issue Type: Bug

unable to fetch kafka lag message count using java

Hi Team, We have been using kafka for messaging service, we can able to fetch the total messages resides in topic, but we would like to know the lag messge(not yet consumed) count for single consumer group,So Can you please tell me, is there a way to fetch lag message count of topic for single c

[GitHub] kafka pull request #4045: KAFKA-6027; Access to log should throw KafkaStorag...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4045 ---

[GitHub] kafka-site issue #95: Change apache-kafka image permission as image not appe...

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/95 @manjuapu I cannot tell what's changed in the image, could you point it out for me? ---

[jira] [Reopened] (KAFKA-5140) Flaky ResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-5140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5140: -- Assignee: Guozhang Wang (was: Matthias J. Sax) Looking into this issue. > Flaky ResetIntegra

[jira] [Created] (KAFKA-6046) DeleteRecordsRequest to a non-leader

Tom Bentley created KAFKA-6046: -- Summary: DeleteRecordsRequest to a non-leader Key: KAFKA-6046 URL: https://issues.apache.org/jira/browse/KAFKA-6046 Project: Kafka Issue Type: Bug Re

[GitHub] kafka-site issue #95: Change apache-kafka image permission as image not appe...

Github user manjuapu commented on the issue: https://github.com/apache/kafka-site/pull/95 @guozhangwang I have tried to change the permission of the image. ---

[GitHub] kafka-site pull request #95: Change apache-kafka image permission as image n...

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/95 ---

[GitHub] kafka-site issue #95: Change apache-kafka image permission as image not appe...

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/95 LGTM. Merged to asf-site. ---

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

See Changes: [junrao] KAFKA-6027; Access to log should throw KafkaStorageException after the -- [...truncated 1.38 MB...] org.apache.kafka.common.record.MemoryRecordsTest

Jenkins build is back to normal : kafka-1.0-jdk7 #19

See

[GitHub] kafka pull request #4048: MINOR: fix EOS test race condition

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4048 ---

[GitHub] kafka pull request #4051: MINOR: KIP-182 follow up

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/4051 MINOR: KIP-182 follow up You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka minor-kip-182-follow-up Alternatively you can review and app

[GitHub] kafka pull request #4052: KAFKA-6046 DeleteRecordsRequest to a non-leader sh...

GitHub user tedyu opened a pull request: https://github.com/apache/kafka/pull/4052 KAFKA-6046 DeleteRecordsRequest to a non-leader should give proper error You can merge this pull request into a Git repository by running: $ git pull https://github.com/tedyu/kafka trunk Altern

[GitHub] kafka pull request #4029: KAFKA-6016: Make the reassign partitions system te...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4029 ---

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

See Changes: [wangguoz] MINOR: fix EOS test race condition [jason] KAFKA-6016; Make the reassign partitions system test use the idempotent -- Started by an SCM change [Env

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

See

[jira] [Created] (KAFKA-6047) Allow retries configuration for InternalTopicManager

Dmitry Vsekhvalnov created KAFKA-6047: - Summary: Allow retries configuration for InternalTopicManager Key: KAFKA-6047 URL: https://issues.apache.org/jira/browse/KAFKA-6047 Project: Kafka

Re: WIKI access request

Hi, Clebert, Thanks for your interest. Just gave you the wiki permission. Jun On Mon, Oct 9, 2017 at 9:26 AM, Clebert Suconic wrote: > If someone could please add my user clebertsuconic with autorization > to create pages. > > I am trying to follow the process lined up here: > > https://cwiki

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

See Changes: [jason] MINOR: Factor out some common group/transactional fields in request -- [...truncated 368.40 KB...] kafka.server.ServerGenerateBrokerIdTest > testMultipleL

[GitHub] kafka pull request #4053: small fix builder -> source

GitHub user bbejeck opened a pull request: https://github.com/apache/kafka/pull/4053 small fix builder -> source You can merge this pull request into a Git repository by running: $ git pull https://github.com/bbejeck/kafka KAFKA_6025_fix_streams_tutorial Alternatively you can

[GitHub] kafka pull request #4035: MINOR: Avoid some unnecessary collection copies in...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4035 ---

[GitHub] kafka pull request #4053: KAFKA-6025: small fix for streams tutorial

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4053 ---

[GitHub] kafka pull request #4051: MINOR: KIP-182 follow up

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4051 ---

[GitHub] kafka pull request #4046: KAFKA-5541: minor follow-up

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4046 ---

[GitHub] kafka pull request #4054: HOTFIX: Updates on release.py before 1.0.0

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/4054 HOTFIX: Updates on release.py before 1.0.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KMinor-pre-1.0-release Alter

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

See Changes: [jason] MINOR: Avoid some unnecessary collection copies in KafkaApis [wangguoz] KAFKA-6025: small fix for streams tutorial [wangguoz] MINOR: KIP-182 follow up; add deprecation annotations to test cl

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

See Changes: [jason] MINOR: Avoid some unnecessary collection copies in KafkaApis -- [...truncated 370.81 KB...] kafka.log.BrokerCompressionTest > testBrokerSideCompression[15

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

Jeyhun, Thanks for the updated KIP, here are my comments. 0. RichInitializer definition seems missing. 1. I'd suggest moving the key parameter in the RichValueXX and RichReducer after the value parameters, as well as in the templates; e.g. public interface RichValueJoiner { VR apply(final V

[jira] [Created] (KAFKA-6048) Support negative record timestamps

Matthias J. Sax created KAFKA-6048: -- Summary: Support negative record timestamps Key: KAFKA-6048 URL: https://issues.apache.org/jira/browse/KAFKA-6048 Project: Kafka Issue Type: Improvement

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

See Changes: [jason] MINOR: Avoid some unnecessary collection copies in KafkaApis -- [...truncated 1.82 MB...] org.apache.kafka.streams.integration.RegexSourceIntegration

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

See Changes: [wangguoz] KAFKA-6025: small fix for streams tutorial [wangguoz] MINOR: KIP-182 follow up; add deprecation annotations to test classes -- [...truncated 371.43 KB

[jira] [Reopened] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-5977: -- > Upgrade RocksDB dependency to legally acceptable version > ---

[jira] [Resolved] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5977. -- Resolution: Fixed > Upgrade RocksDB dependency to legally acceptable version > -

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

See Changes: [jason] MINOR: Avoid some unnecessary collection copies in KafkaApis -- [...truncated 3.28 MB...] kafka.security.auth.SimpleAclAuthorizerTest > testAclInherit

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

See

[jira] [Created] (KAFKA-6049) Kafka Streams: Add Cogroup in the DSL

Guozhang Wang created KAFKA-6049: Summary: Kafka Streams: Add Cogroup in the DSL Key: KAFKA-6049 URL: https://issues.apache.org/jira/browse/KAFKA-6049 Project: Kafka Issue Type: New Feature

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

See Changes: [wangguoz] KAFKA-6025: small fix for streams tutorial [wangguoz] MINOR: KIP-182 follow up; add deprecation annotations to test classes [wangguoz] KAFKA-5541: Follow-up; Try to clean uncleanly upon

[VOTE] 1.0.0 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 1.0.0. It's worth noting that starting in this version we are using a different version protocol with three digits: *major.minor.bug-fix* Any and all testing is welcome, but the following

Re: [VOTE] 1.0.0 RC0

Guozhang: I took a brief look under the staging tree. e.g. https://repository.apache.org/content/groups/staging/org/apache/kafka/kafka-clients/ I don't see 1.0.0 jars. Would the jars be populated later ? Thanks On Tue, Oct 10, 2017 at 6:34 PM, Guozhang Wang wrote: > Hello Kafka users, develop

[GitHub] kafka pull request #3750: KafkaConsumer was hung when bootstrap servers was ...

Github user kyleabcha closed the pull request at: https://github.com/apache/kafka/pull/3750 ---