Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/3819
---
GitHub user jeffwidman opened a pull request:
https://github.com/apache/kafka/pull/4032
MINOR: Fix typo
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeffwidman/kafka patch-3
Alternatively you can review and apply these change
GitHub user guozhangwang opened a pull request:
https://github.com/apache/kafka/pull/4031
MINOR: log4j improvements on assigned tasks and store changelog reader
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/guozhangwang/kafka K
We should split KAFKA-4499 into several sub-issues with 4499 being the
parent issue.
Adding the implementation to CachingWindowStore, RocksDBWindowStore, etc
will each require the addition of a test and implementing the methods which
is not trivial.
This way, it should be easier to manage the progr
You can update your properties file in the same way with the current
clients, right? I don't understand how mapping properties into a single
string makes things easier.
Ismael
On Thu, Oct 5, 2017 at 11:22 PM, Clebert Suconic
wrote:
> Another useful feature for this...
>
> Say that I am writing
Github user guozhangwang closed the pull request at:
https://github.com/apache/kafka/pull/3607
---
Hi Gilles,
Thanks for your interest in contributing, has added you to the list.
Cheers,
Guozhang
On Thu, Oct 5, 2017 at 1:09 PM, Gilles Degols wrote:
> Hello,
>
>
>
> As I use Kafka during my day-job I would like to contribute to the project
> in my spare time. According the kafka.apache.org w
Another useful feature for this...
Say that I am writing an application... if I write this URI on any of
my internal properties.. I can tweak my Consumer or Producer without
changing any code.
Say, you store the URI on your project's configuration xml..read it
and start your consumer... later on
Jorge,
KIP-198 (that got merged already) overlaps with this KIP. Can you please
update your KIP accordingly?
Also, while working on KIP-198, we identified some shortcomings in
AdminClient that do not allow us to move StreamsResetter our of core
package. We want to address those shortcoming in ano
Thanks for driving this and sorry for late response. With release
deadline it was pretty busy lately.
Can you please add a description for the suggested method, what they are
going to return? It's a little unclear to me atm.
It would also be helpful to discuss, for which use case each method is
u
GitHub user kkonstantine opened a pull request:
https://github.com/apache/kafka/pull/4030
KAFKA-5953: Register all jdbc drivers available in plugin and class paths
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kkonstantine/kafk
GitHub user apurvam opened a pull request:
https://github.com/apache/kafka/pull/4029
KAFKA-6016: Make the reassign partitions system test use the idempotent
producer
With these changes, we are ensuring that the partitions being reassigned
are from non-zero offsets. We also ensure t
To me, this is a lot more in line with many other systems connections, to have
the ability to have a single connection string / uri, is this really that left
field suggesting or wanting this?
If anything this bring kafka more standardised approach imo, to have a unified
resource identifier, pro
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/4028
---
Github user asfgit closed the pull request at:
https://github.com/apache/kafka-site/pull/90
---
Github user junrao commented on the issue:
https://github.com/apache/kafka-site/pull/90
@derrickdoo : Thanks for the patch. LGTM
---
GitHub user derrickdoo opened a pull request:
https://github.com/apache/kafka/pull/4028
Update docs to reflect kafka trademark status
Updated a couple places in docs with the 'registered' trademark symbol.
You can merge this pull request into a Git repository by running:
$ git
Hello,
As I use Kafka during my day-job I would like to contribute to the project
in my spare time. According the kafka.apache.org website, I need someone to
add me to the contributor list, to assign myself some JIRA tickets.
Could someone add me to the contributor list (username: gilles.dego
Github user dguy closed the pull request at:
https://github.com/apache/kafka/pull/4025
---
GitHub user lisa2lisa opened a pull request:
https://github.com/apache/kafka/pull/4027
MINOR: fix inconsistance
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lisa2lisa/kafka typo-fix
Alternatively you can review and apply thes
[
https://issues.apache.org/jira/browse/KAFKA-2376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-2376.
--
Resolution: Fixed
All of the subtasks have been completed, so marking this as fixed.
> Add Kafk
GitHub user derrickdoo opened a pull request:
https://github.com/apache/kafka-site/pull/90
Kafka registered trademark
Update art assets and content to reflect registered status of the Kafka
trademark
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/KAFKA-5904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-5904.
--
Resolution: Fixed
Resolved as part of the [PR](https://github.com/apache/kafka/pull/4011) for
K
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4026
KAFKA-5746: Document new broker metrics added for health checks
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka MINOR-
On Thu, Oct 5, 2017 at 2:20 PM, Colin McCabe wrote:
> We used URIs as file paths in Hadoop. I think it was a mistake, for a
> few different reasons.
>
> URIs are actually very complex. You probably know about scheme, host,
> and port, but did you know about authority, user-info, query, fragment,
Hi Colin,
Is it really true that "the period when the offset is unavailable should be
brief"? I'm thinking about a producer with acks=1, so the old leader
returns the ProduceResponse immediately and then is replaced before it can
sent a FetchResponse to any followers. The new leader is then waitin
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/4011
---
[
https://issues.apache.org/jira/browse/KAFKA-5903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ewen Cheslack-Postava resolved KAFKA-5903.
--
Resolution: Fixed
Issue resolved by pull request 4011
[https://github.com/apache
Hi all,
I created a KIP for discussion about fixing a corner case in
ListOffsetsResponse. Check it out at:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-207%3A+Offsets+returned+by+ListOffsetsResponse+should+be+monotonically+increasing+even+during+a+partition+leader+change
cheers,
Colin
We used URIs as file paths in Hadoop. I think it was a mistake, for a
few different reasons.
URIs are actually very complex. You probably know about scheme, host,
and port, but did you know about authority, user-info, query, fragment,
scheme-specific-part? Do you know what they do in Hadoop? T
Github user joel-hamill closed the pull request at:
https://github.com/apache/kafka-site/pull/89
---
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/4017
---
[
https://issues.apache.org/jira/browse/KAFKA-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-6012.
---
Resolution: Fixed
Fix Version/s: 1.1.0
Issue resolved by pull request 4024
[https://git
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/4024
---
GitHub user dguy opened a pull request:
https://github.com/apache/kafka/pull/4025
KAFKA-5989: resume consumption of tasks that have state stores but no
changelogging
Stores where logging is disabled where never consumed as the partitions
were paused, but never resumed.
You can mer
Github user asfgit closed the pull request at:
https://github.com/apache/kafka/pull/4002
---
I can start a KIP discussion on this.. or not if you really think this
is against basic rules...
I will need authorization to create the page.. if you could assign me
regardless so I can have it for next time?
On Thu, Oct 5, 2017 at 10:31 AM, Clebert Suconic
wrote:
> Just as a facility for user
[
https://issues.apache.org/jira/browse/KAFKA-5978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-5978.
---
Resolution: Fixed
Assignee: Rajini Sivaram
This could be because the times are too small
Just as a facility for users... I think it would be easier to
prototype consumers and producer by simply doing new
Consumer("tcp://HOST:PORT") or new Producer("tcp://HOST:PORT")...
on the other project I work (ActiveMQ Artemis) we used to do a similar
way to what Kafka does..we then provided the U
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/4024
KAFKA-6012: Close request metrics only after closing request handlers
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka
Hey Clebert,
Is there a motivation for adding a second way? We generally try to avoid
having two ways to do something unless it's really needed...I suspect you
have a reason for wanting this, though.
-Jay
On Mon, Oct 2, 2017 at 6:15 AM Clebert Suconic
wrote:
> At ActiveMQ and ActiveMQ Artemis,
GitHub user ijuma opened a pull request:
https://github.com/apache/kafka/pull/4023
KAFKA-5829: Only delete producer snapshots before the recovery point
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ijuma/kafka
kafka-5829-avoid
I'd like to raise a somewhat subtle point about how the proposed API should
behave.
The current CreateTopicPolicy gets passed either the request partition
count and replication factor, or the requested assignment. So if the
request had specified partition count and replication factor, the policy
s
[
https://issues.apache.org/jira/browse/KAFKA-5877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-5877.
-
Resolution: Fixed
> Controller should only update reassignment znode if there is change in the
> reassign
Github user lindong28 closed the pull request at:
https://github.com/apache/kafka/pull/3839
---
45 matches
Mail list logo
